File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -357,8 +357,12 @@ fn build_non_case_left_join_df_with_push_down_filter(
357357fn find_filter_predicates ( plan : & LogicalPlan ) -> Vec < datafusion_expr:: Expr > {
358358 match plan {
359359 LogicalPlan :: Filter ( filter) => split_conjunction_owned ( filter. predicate . clone ( ) ) ,
360- LogicalPlan :: Projection ( projection) => find_filter_predicates ( projection. input . as_ref ( ) ) ,
361- other => panic ! ( "expected benchmark query plan to contain a Filter, found {other:?}" ) ,
360+ LogicalPlan :: Projection ( projection) => {
361+ find_filter_predicates ( projection. input . as_ref ( ) )
362+ }
363+ other => {
364+ panic ! ( "expected benchmark query plan to contain a Filter, found {other:?}" )
365+ }
362366 }
363367}
364368
@@ -375,7 +379,8 @@ fn assert_case_heavy_left_join_inference_candidates(
375379 for predicate in predicates {
376380 let column_refs = predicate. column_refs ( ) ;
377381 assert ! (
378- column_refs. contains( &&left_join_key) || column_refs. contains( &&right_join_key) ,
382+ column_refs. contains( &&left_join_key)
383+ || column_refs. contains( &&right_join_key) ,
379384 "benchmark predicate should reference a join key: {predicate}"
380385 ) ;
381386 assert ! (
You can’t perform that action at this time.
0 commit comments