Skip to content

Commit

Permalink
Minor: refactor ParquetExec roundtrip tests (#5260)
Browse files Browse the repository at this point in the history
* Minor: refactor ParquetExec roundtrip tests

* Apply suggestions from code review

Co-authored-by: Liang-Chi Hsieh <viirya@gmail.com>

---------

Co-authored-by: Liang-Chi Hsieh <viirya@gmail.com>
  • Loading branch information
alamb and viirya authored Feb 13, 2023
1 parent 00e60f1 commit 9710d7c
Show file tree
Hide file tree
Showing 2 changed files with 171 additions and 109 deletions.
6 changes: 6 additions & 0 deletions datafusion/core/src/datasource/file_format/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -550,6 +550,12 @@ pub(crate) mod test_util {
use parquet::file::properties::WriterProperties;
use tempfile::NamedTempFile;

/// Writes `batches` to a temporary parquet file
///
/// If multi_page is set to `true`, all batches are written into
/// one temporary parquet file and the parquet file is written
/// with 2 rows per data page (used to test page filtering and
/// boundaries).
pub async fn store_parquet(
batches: Vec<RecordBatch>,
multi_page: bool,
Expand Down
Loading

0 comments on commit 9710d7c

Please sign in to comment.