File tree Expand file tree Collapse file tree 2 files changed +10
-9
lines changed
Expand file tree Collapse file tree 2 files changed +10
-9
lines changed Original file line number Diff line number Diff line change @@ -32,15 +32,16 @@ pub(crate) fn make_vortex_predicate(
3232 . iter ( )
3333 . filter_map ( |e| {
3434 if is_dynamic_physical_expr ( e) {
35- let e = snapshot_physical_expr ( e. clone ( ) ) . expect ( "do" ) ;
36- match Expression :: try_from_df ( e. as_ref ( ) ) {
37- Ok ( e) => Some ( Ok ( e) ) ,
38- Err ( _) => {
39- // If we fail to convert the expression to Vortex, its safe
40- // to drop it as we don't declare it as pushed down
41- None
35+ snapshot_physical_expr ( e. clone ( ) ) . ok ( ) . and_then ( |e| {
36+ match Expression :: try_from_df ( e. as_ref ( ) ) {
37+ Ok ( e) => Some ( Ok ( e) ) ,
38+ Err ( _) => {
39+ // If we fail to convert the expression to Vortex, its safe
40+ // to drop it as we don't declare it as pushed down
41+ None
42+ }
4243 }
43- }
44+ } )
4445 } else {
4546 Some ( Expression :: try_from_df ( e. as_ref ( ) ) )
4647 }
Original file line number Diff line number Diff line change @@ -295,11 +295,11 @@ impl FileOpener for VortexOpener {
295295 . and_then ( |f| {
296296 let exprs = split_conjunction ( & f)
297297 . into_iter ( )
298- . cloned ( )
299298 . filter ( |expr| {
300299 is_dynamic_physical_expr ( expr)
301300 || can_be_pushed_down ( expr, & predicate_file_schema)
302301 } )
302+ . cloned ( )
303303 . collect :: < Vec < _ > > ( ) ;
304304
305305 make_vortex_predicate ( & exprs) . transpose ( )
You can’t perform that action at this time.
0 commit comments