File tree Expand file tree Collapse file tree 1 file changed +8
-9
lines changed
datafusion/physical-expr/src/expressions Expand file tree Collapse file tree 1 file changed +8
-9
lines changed Original file line number Diff line number Diff line change @@ -1352,15 +1352,14 @@ impl CaseExpr {
13521352
13531353 let else_rows = & branch_rows[ lookup_table. num_branches ] ;
13541354 if !else_rows. is_empty ( )
1355- && let Some ( else_expr) = & self . body . else_expr {
1356- let row_indices =
1357- Arc :: new ( UInt32Array :: from ( else_rows. clone ( ) ) ) as ArrayRef ;
1358- let filter_predicate = create_filter_from_indices ( else_rows, row_count) ;
1359- let filtered_batch =
1360- filter_record_batch ( & working_batch, & filter_predicate) ?;
1361- let else_value = else_expr. evaluate ( & filtered_batch) ?;
1362- result_builder. add_branch_result ( & row_indices, else_value) ?;
1363- }
1355+ && let Some ( else_expr) = & self . body . else_expr
1356+ {
1357+ let row_indices = Arc :: new ( UInt32Array :: from ( else_rows. clone ( ) ) ) as ArrayRef ;
1358+ let filter_predicate = create_filter_from_indices ( else_rows, row_count) ;
1359+ let filtered_batch = filter_record_batch ( & working_batch, & filter_predicate) ?;
1360+ let else_value = else_expr. evaluate ( & filtered_batch) ?;
1361+ result_builder. add_branch_result ( & row_indices, else_value) ?;
1362+ }
13641363
13651364 result_builder. finish ( )
13661365 }
You can’t perform that action at this time.
0 commit comments