File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed
Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -357,12 +357,8 @@ 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) => {
361- find_filter_predicates ( projection. input . as_ref ( ) )
362- }
363- other => {
364- panic ! ( "expected benchmark query plan to contain a Filter, found {other:?}" )
365- }
360+ LogicalPlan :: Projection ( projection) => find_filter_predicates ( projection. input . as_ref ( ) ) ,
361+ other => panic ! ( "expected benchmark query plan to contain a Filter, found {other:?}" ) ,
366362 }
367363}
368364
@@ -379,8 +375,7 @@ fn assert_case_heavy_left_join_inference_candidates(
379375 for predicate in predicates {
380376 let column_refs = predicate. column_refs ( ) ;
381377 assert ! (
382- column_refs. contains( &&left_join_key)
383- || column_refs. contains( &&right_join_key) ,
378+ column_refs. contains( &&left_join_key) || column_refs. contains( &&right_join_key) ,
384379 "benchmark predicate should reference a join key: {predicate}"
385380 ) ;
386381 assert ! (
You can’t perform that action at this time.
0 commit comments