File tree Expand file tree Collapse file tree 2 files changed +2
-9
lines changed
core/src/physical_plan/file_format Expand file tree Collapse file tree 2 files changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -1278,11 +1278,6 @@ mod tests {
1278
1278
. await
1279
1279
. unwrap ( ) ;
1280
1280
1281
- // This does not look correct since the "c2" values in the result do not in fact match the predicate `c2 == 0`
1282
- // but parquet pruning is not exact. If the min/max values are not defined (which they are not in this case since the it is
1283
- // a null array, then the pruning predicate (currently) can not be applied.
1284
- // In a real query where this predicate was pushed down from a filter stage instead of created directly in the `ParquetExec`,
1285
- // the filter stage would be preserved as a separate execution plan stage so the actual query results would be as expected.
1286
1281
let expected = vec ! [
1287
1282
"+----+----+" ,
1288
1283
"| c1 | c2 |" ,
Original file line number Diff line number Diff line change @@ -479,10 +479,8 @@ pub fn combine_filters_disjunctive(filters: &[Expr]) -> Option<Expr> {
479
479
if filters. is_empty ( ) {
480
480
return None ;
481
481
}
482
- let combined_filter = filters
483
- . iter ( )
484
- . reduce ( |acc, filter| or ( acc, filter. clone ( ) ) ) ;
485
- Some ( combined_filter)
482
+
483
+ filters. iter ( ) . cloned ( ) . reduce ( or)
486
484
}
487
485
488
486
/// Recursively un-alias an expressions
You can’t perform that action at this time.
0 commit comments