File tree 3 files changed +3
-9
lines changed 3 files changed +3
-9
lines changed Original file line number Diff line number Diff line change @@ -114,7 +114,7 @@ pub fn check_filtered_batch_handle(
114
114
for child in plan. children ( ) {
115
115
if !child. output_filtered_batches ( ) {
116
116
let plan_str = get_plan_string ( & plan) ;
117
- let child_str = get_plan_string ( & child) ;
117
+ let child_str = get_plan_string ( child) ;
118
118
return plan_err ! (
119
119
"Plan {:?} required filtered batches but its child {:?} won't produce them" ,
120
120
plan_str,
Original file line number Diff line number Diff line change @@ -1020,10 +1020,7 @@ impl ExecutionPlan for AggregateExec {
1020
1020
}
1021
1021
1022
1022
fn requried_filtered_input ( & self ) -> bool {
1023
- match self . mode ( ) {
1024
- AggregateMode :: FinalPartitioned ( HashPartitionMode :: SelectionBitmap ) => true ,
1025
- _ => false ,
1026
- }
1023
+ matches ! ( self . mode( ) , AggregateMode :: FinalPartitioned ( HashPartitionMode :: SelectionBitmap ) )
1027
1024
}
1028
1025
}
1029
1026
Original file line number Diff line number Diff line change @@ -653,10 +653,7 @@ impl ExecutionPlan for RepartitionExec {
653
653
}
654
654
655
655
fn output_filtered_batches ( & self ) -> bool {
656
- match self . partitioning ( ) {
657
- Partitioning :: HashSelectionBitmap ( _, _) => true ,
658
- _ => false ,
659
- }
656
+ matches ! ( self . partitioning( ) , Partitioning :: HashSelectionBitmap ( _, _) )
660
657
}
661
658
662
659
fn execute (
You can’t perform that action at this time.
0 commit comments