File tree 2 files changed +2
-9
lines changed
core/src/physical_plan/file_format
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 @@ -456,10 +456,8 @@ pub fn combine_filters_disjunctive(filters: &[Expr]) -> Option<Expr> {
456
456
if filters. is_empty ( ) {
457
457
return None ;
458
458
}
459
- let combined_filter = filters
460
- . iter ( )
461
- . reduce ( |acc, filter| or ( acc, filter. clone ( ) ) ) ;
462
- Some ( combined_filter)
459
+
460
+ filters. iter ( ) . cloned ( ) . reduce ( or)
463
461
}
464
462
465
463
/// Recursively un-alias an expressions
You can’t perform that action at this time.
0 commit comments