rewrite_expr

common_function::aggrs::aggr_wrapper::fix_order

Function rewrite_expr 

Source 
fn rewrite_expr(
    expr: Expr,
    aggregate_input: &Arc<LogicalPlan>,
    is_fix: bool,
) -> Result<Transformed<Expr>, DataFusionError>
Expand description

first see the aggr node in expr as it could be nested aggr like alias(aggr(sort)) if contained aggr expr have a order by, and the aggr name match the regex then we need to fix the ordering field of the state udaf to be the same as the aggr expr