Skip to content

Commit

Permalink
Use simple first check
Browse files Browse the repository at this point in the history
  • Loading branch information
stijnherfst committed Nov 25, 2024
1 parent ab2d8e6 commit e28655c
Showing 1 changed file with 9 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,16 @@ fn add_keys_to_accumulated_state(
// the JOIN executor
if add_local {
// return the left most name as output name
let names = aexpr_to_leaf_names_iter(expr, expr_arena).collect::<Vec<_>>();
let output_name = names.first().cloned();
let names = aexpr_to_leaf_names_iter(expr, expr_arena);

let mut first = true;
let mut output_name = None;
for name in names {
if first {
output_name = Some(name.clone());
first = false;
}

let node = expr_arena.add(AExpr::Column(name));
local_projection.push(ColumnNode(node));
}
Expand Down

0 comments on commit e28655c

Please sign in to comment.