We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent be068d8 commit 90a5ea4Copy full SHA for 90a5ea4
datafusion/core/src/datasource/physical_plan/parquet/statistics.rs
@@ -874,10 +874,11 @@ impl<'a> StatisticsConverter<'a> {
874
where
875
I: IntoIterator<Item = &'a RowGroupMetaData>,
876
{
877
- let data_type = self.arrow_field.data_type();
878
-
879
let Some(parquet_index) = self.parquet_index else {
880
- return Ok(self.make_null_array(data_type, metadatas));
+ let num_row_groups = metadatas.into_iter().count();
+ return Ok(Arc::new(UInt64Array::from_iter(
+ std::iter::repeat(None).take(num_row_groups),
881
+ )));
882
};
883
884
let null_counts = metadatas
0 commit comments