File tree Expand file tree Collapse file tree 1 file changed +8
-10
lines changed
native/core/src/execution/operators Expand file tree Collapse file tree 1 file changed +8
-10
lines changed Original file line number Diff line number Diff line change @@ -212,17 +212,15 @@ impl FilterExec {
212
212
if binary. op ( ) == & Operator :: Eq {
213
213
// Filter evaluates to single value for all partitions
214
214
if input_eqs. is_expr_constant ( binary. left ( ) ) . is_some ( ) {
215
- let ( expr, across_parts) = (
216
- binary. right ( ) ,
217
- input_eqs. get_expr_constant_value ( binary. right ( ) ) ,
218
- ) ;
219
- res_constants. push ( ConstExpr :: new ( Arc :: clone ( expr) , across_parts) ) ;
215
+ let across = input_eqs
216
+ . is_expr_constant ( binary. right ( ) )
217
+ . unwrap_or_default ( ) ;
218
+ res_constants. push ( ConstExpr :: new ( Arc :: clone ( binary. right ( ) ) , across) ) ;
220
219
} else if input_eqs. is_expr_constant ( binary. right ( ) ) . is_some ( ) {
221
- let ( expr, across_parts) = (
222
- binary. left ( ) ,
223
- input_eqs. get_expr_constant_value ( binary. left ( ) ) ,
224
- ) ;
225
- res_constants. push ( ConstExpr :: new ( Arc :: clone ( expr) , across_parts) ) ;
220
+ let across = input_eqs
221
+ . is_expr_constant ( binary. left ( ) )
222
+ . unwrap_or_default ( ) ;
223
+ res_constants. push ( ConstExpr :: new ( Arc :: clone ( binary. left ( ) ) , across) ) ;
226
224
}
227
225
}
228
226
}
You can’t perform that action at this time.
0 commit comments