File tree Expand file tree Collapse file tree 2 files changed +2
-28
lines changed
polars-mem-engine/src/planner Expand file tree Collapse file tree 2 files changed +2
-28
lines changed Original file line number Diff line number Diff line change @@ -44,34 +44,6 @@ pub(crate) fn predicate_at_all_scans(q: LazyFrame) -> bool {
44
44
} )
45
45
}
46
46
47
- #[ cfg( feature = "streaming" ) ]
48
- pub ( crate ) fn is_pipeline ( q : LazyFrame ) -> bool {
49
- let ( mut expr_arena, mut lp_arena) = get_arenas ( ) ;
50
- let lp = q. optimize ( & mut lp_arena, & mut expr_arena) . unwrap ( ) ;
51
- matches ! (
52
- lp_arena. get( lp) ,
53
- IR :: MapFunction {
54
- function: FunctionIR :: Pipeline { .. } ,
55
- ..
56
- }
57
- )
58
- }
59
-
60
- #[ cfg( feature = "streaming" ) ]
61
- pub ( crate ) fn has_pipeline ( q : LazyFrame ) -> bool {
62
- let ( mut expr_arena, mut lp_arena) = get_arenas ( ) ;
63
- let lp = q. optimize ( & mut lp_arena, & mut expr_arena) . unwrap ( ) ;
64
- ( & lp_arena) . iter ( lp) . any ( |( _, lp) | {
65
- matches ! (
66
- lp,
67
- IR :: MapFunction {
68
- function: FunctionIR :: Pipeline { .. } ,
69
- ..
70
- }
71
- )
72
- } )
73
- }
74
-
75
47
#[ cfg( any( feature = "parquet" , feature = "csv" ) ) ]
76
48
fn slice_at_scan ( q : LazyFrame ) -> bool {
77
49
let ( mut expr_arena, mut lp_arena) = get_arenas ( ) ;
Original file line number Diff line number Diff line change @@ -485,11 +485,13 @@ fn create_physical_plan_impl(
485
485
predicate_has_windows : state. has_windows ,
486
486
} ) )
487
487
} ,
488
+ #[ allow( unreachable_patterns) ]
488
489
_ => {
489
490
let build_func = build_streaming_executor
490
491
. expect ( "invalid build. Missing feature new-streaming" ) ;
491
492
return build_func ( root, lp_arena, expr_arena) ;
492
493
} ,
494
+ #[ allow( unreachable_patterns) ]
493
495
_ => unreachable ! ( ) ,
494
496
}
495
497
} ,
You can’t perform that action at this time.
0 commit comments