File tree Expand file tree Collapse file tree 2 files changed +5
-6
lines changed
core/tests/physical_optimizer/filter_pushdown Expand file tree Collapse file tree 2 files changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -2661,11 +2661,10 @@ fn test_hash_join_dynamic_filter_with_unsupported_scan() {
26612661 . unwrap ( ) ,
26622662 ) ;
26632663
2664- let mut config = ConfigOptions :: default ( ) ;
2665- config. optimizer . enable_dynamic_filter_pushdown = true ;
2666-
2664+ let config = SessionConfig :: new ( ) ;
26672665 let rule = FilterPushdown :: new_post_optimization ( ) ;
2668- let plan = rule. optimize ( join, & config) . unwrap ( ) ;
2666+ let ctx = OptimizerContext :: new ( config. clone ( ) ) ;
2667+ let plan = rule. optimize_plan ( join, & ctx) . unwrap ( ) ;
26692668
26702669 // Optimized plan should not have a DynamicFilter placeholder in the probe node.
26712670 insta:: assert_snapshot!(
Original file line number Diff line number Diff line change @@ -114,10 +114,10 @@ impl Default for SessionConfig {
114114}
115115
116116/// A type map for storing extensions.
117- ///
117+ ///
118118/// Extensions are indexed by their type `T`. If multiple values of the same type are provided, only the last one
119119/// will be kept.
120- ///
120+ ///
121121/// Extensions are opaque objects that are unknown to DataFusion itself but can be downcast by optimizer rules,
122122/// execution plans, or other components that have access to the session config.
123123/// They provide a flexible way to attach extra data or behavior to the session config.
You can’t perform that action at this time.
0 commit comments