Skip to content

Commit ae1e57c

Browse files
committed
Revert "avoid a collect"
This reverts commit 86f8079.
1 parent 86f8079 commit ae1e57c

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

datafusion/src/physical_plan/parquet.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -512,7 +512,7 @@ macro_rules! get_min_max_values {
512512
return None
513513
};
514514

515-
let scalar_values = $self.row_group_metadata
515+
let scalar_values : Vec<ScalarValue> = $self.row_group_metadata
516516
.iter()
517517
.flat_map(|meta| {
518518
meta.column(column_index).statistics()
@@ -523,10 +523,11 @@ macro_rules! get_min_max_values {
523523
.map(|maybe_scalar| {
524524
// column either did't have statistics at all or didn't have min/max values
525525
maybe_scalar.unwrap_or_else(|| null_scalar.clone())
526-
});
526+
})
527+
.collect();
527528

528529
// ignore errors converting to arrays (e.g. different types)
529-
ScalarValue::iter_to_array(scalar_values).ok()
530+
ScalarValue::iter_to_array(scalar_values.iter()).ok()
530531
}}
531532
}
532533

0 commit comments

Comments
 (0)