Skip to content

Commit 41e92da

Browse files
committed
WIP: Avoid row_group_ordinal
1 parent 0774580 commit 41e92da

File tree

1 file changed

+1
-2
lines changed
  • datafusion/core/src/datasource/file_format

1 file changed

+1
-2
lines changed

datafusion/core/src/datasource/file_format/parquet.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -935,8 +935,7 @@ fn spawn_column_parallel_row_group_writer(
935935
pool: &Arc<dyn MemoryPool>,
936936
) -> Result<(Vec<ColumnWriterTask>, Vec<ColSender>)> {
937937
let schema_desc = arrow_to_parquet_schema(&schema)?;
938-
let row_group_ordinal_unused = 0;
939-
let col_writers = get_column_writers(&schema_desc, &parquet_props, &schema, row_group_ordinal_unused)?;
938+
let col_writers = get_column_writers(&schema_desc, &parquet_props, &schema, None)?;
940939
let num_columns = col_writers.len();
941940

942941
let mut col_writer_tasks = Vec::with_capacity(num_columns);

0 commit comments

Comments
 (0)