@@ -328,6 +328,8 @@ mod tests {
328328 use datafusion_functions:: expr_fn:: get_field;
329329 use datafusion_physical_expr:: PhysicalExpr ;
330330 use datafusion_physical_expr:: create_physical_expr;
331+ use datafusion_physical_expr:: planner:: logical2physical;
332+ use datafusion_physical_expr:: { PhysicalExpr , create_physical_expr} ;
331333 use datafusion_physical_plan:: expressions as df_expr;
332334 use datafusion_physical_plan:: filter_pushdown:: PushedDown ;
333335 use insta:: assert_snapshot;
@@ -677,8 +679,7 @@ mod tests {
677679
678680 let df_schema = test_schema. clone ( ) . to_dfschema ( ) . unwrap ( ) ;
679681
680- let physical_filter =
681- create_physical_expr ( & filter, & df_schema, & ExecutionProps :: default ( ) ) . unwrap ( ) ;
682+ let physical_filter = logical2physical ( & filter, df_schema. as_ref ( ) ) . unwrap ( ) ;
682683
683684 let source = vortex_source ( & test_schema) ;
684685
@@ -714,8 +715,7 @@ mod tests {
714715
715716 let deep_filter = get_field ( get_field ( col ( "a" ) , "b" ) , "c" ) . eq ( datafusion_expr:: lit ( 10i32 ) ) ;
716717
717- let physical_filter =
718- create_physical_expr ( & deep_filter, & df_schema, & ExecutionProps :: default ( ) ) . unwrap ( ) ;
718+ let physical_filter = logical2physical ( & deep_filter, & df_schema. as_ref ( ) ) . unwrap ( ) ;
719719
720720 let prop = source
721721 . try_pushdown_filters ( vec ! [ physical_filter] , & ConfigOptions :: default ( ) )
@@ -787,8 +787,7 @@ mod tests {
787787 // Another weird ScalarFunction that we can't push down
788788 let deep_filter = unknown_func. eq ( datafusion_expr:: lit ( 10i32 ) ) ;
789789
790- let physical_filter =
791- create_physical_expr ( & deep_filter, & df_schema, & ExecutionProps :: default ( ) ) . unwrap ( ) ;
790+ let physical_filter = logical2physical ( & deep_filter, & df_schema. as_ref ( ) ) . unwrap ( ) ;
792791
793792 let prop = source
794793 . try_pushdown_filters ( vec ! [ physical_filter] , & ConfigOptions :: default ( ) )
0 commit comments