File tree Expand file tree Collapse file tree
datafusion/core/tests/physical_optimizer/filter_pushdown Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1943,11 +1943,8 @@ async fn run_aggregate_dyn_filter_case(case: AggregateDynFilterCase<'_>) {
19431943 config. execution . parquet . pushdown_filters = true ;
19441944 config. optimizer . enable_dynamic_filter_pushdown = true ;
19451945
1946- let session_config: SessionConfig = config. into ( ) ;
1947- let optimizer_context = OptimizerContext :: new ( session_config) ;
1948-
19491946 let optimized = FilterPushdown :: new_post_optimization ( )
1950- . optimize_plan ( plan, & optimizer_context )
1947+ . optimize ( plan, & config )
19511948 . unwrap ( ) ;
19521949
19531950 let before = format_plan_for_test ( & optimized) ;
@@ -2309,11 +2306,8 @@ fn test_aggregate_dynamic_filter_not_created_for_single_mode() {
23092306 config. execution . parquet . pushdown_filters = true ;
23102307 config. optimizer . enable_dynamic_filter_pushdown = true ;
23112308
2312- let session_config: SessionConfig = config. into ( ) ;
2313- let optimizer_context = OptimizerContext :: new ( session_config) ;
2314-
23152309 let optimized = FilterPushdown :: new_post_optimization ( )
2316- . optimize_plan ( plan, & optimizer_context )
2310+ . optimize ( plan, & config )
23172311 . unwrap ( ) ;
23182312
23192313 let formatted = format_plan_for_test ( & optimized) ;
You can’t perform that action at this time.
0 commit comments