Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb committed Jul 12, 2023
1 parent da911a3 commit de7b250
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion datafusion/core/src/physical_plan/aggregates/row_hash.rs
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,10 @@ fn create_group_accumulator(
agg_expr.create_groups_accumulator()
} else {
// Note in the log when the slow path is used
debug!("Creating GroupsAccumulatorAdapter for {}: {agg_expr:?}", agg_expr.name());
debug!(
"Creating GroupsAccumulatorAdapter for {}: {agg_expr:?}",
agg_expr.name()
);
let agg_expr_captured = agg_expr.clone();
let factory = move || agg_expr_captured.create_accumulator();
Ok(Box::new(GroupsAccumulatorAdapter::new(factory)))
Expand Down

0 comments on commit de7b250

Please sign in to comment.