Skip to content

Commit

Permalink
add parquet
Browse files Browse the repository at this point in the history
  • Loading branch information
thomas-k-cameron committed Dec 10, 2023
1 parent ba6ab9e commit ac00cfa
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions datafusion/core/src/datasource/file_format/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -180,8 +180,11 @@ impl FileFormat for ParquetFormat {
.await?;

schemas.sort_by(|(location1, _), (location2, _)| location1.cmp(location2));

let schemas = schemas.into_iter().map(|(_, schema)| schema).collect::<Vec<_>>();

let schemas = schemas
.into_iter()
.map(|(_, schema)| schema)
.collect::<Vec<_>>();

let schema = if self.skip_metadata(state.config_options()) {
Schema::try_merge(clear_metadata(schemas))
Expand Down

0 comments on commit ac00cfa

Please sign in to comment.