Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
jayzhan211 committed Feb 25, 2025
1 parent e95018f commit fadf6e3
Showing 1 changed file with 20 additions and 2 deletions.
22 changes: 20 additions & 2 deletions datafusion/functions-aggregate/src/planner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,10 +56,28 @@ impl ExprPlanner for AggregateFunctionPlanner {

let saved_name = NamePreserver::new_for_projection().save(&origin_expr);

let Expr::AggregateFunction(AggregateFunction { func, params: AggregateFunctionParams { args, distinct, filter, order_by, null_treatment } }) = origin_expr else {
let Expr::AggregateFunction(AggregateFunction {
func,
params:
AggregateFunctionParams {
args,
distinct,
filter,
order_by,
null_treatment,
},
}) = origin_expr
else {
unreachable!("")
};
let raw_expr = RawAggregateExpr { func, args, distinct, filter, order_by, null_treatment };
let raw_expr = RawAggregateExpr {
func,
args,
distinct,
filter,
order_by,
null_treatment,
};

// handle count() and count(*) case
// convert to count(1) as "count()"
Expand Down

0 comments on commit fadf6e3

Please sign in to comment.