Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
Fixed example and bench
Browse files Browse the repository at this point in the history
  • Loading branch information
jorgecarleitao committed May 26, 2022
1 parent 1014a52 commit b60c454
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 3 deletions.
2 changes: 1 addition & 1 deletion benches/write_parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ fn write(array: &dyn Array, encoding: Encoding) -> Result<()> {
vec![Ok(columns)].into_iter(),
&schema,
options,
vec![encoding],
vec![vec![encoding]],
)?;

let writer = vec![];
Expand Down
8 changes: 6 additions & 2 deletions examples/parquet_write.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,12 @@ fn write_batch(path: &str, schema: Schema, columns: Chunk<Arc<dyn Array>>) -> Re

let iter = vec![Ok(columns)];

let row_groups =
RowGroupIterator::try_new(iter.into_iter(), &schema, options, vec![Encoding::Plain])?;
let row_groups = RowGroupIterator::try_new(
iter.into_iter(),
&schema,
options,
vec![vec![Encoding::Plain]],
)?;

// Create a new empty file
let file = File::create(path)?;
Expand Down

0 comments on commit b60c454

Please sign in to comment.