flow::df_optimizer

Function expand_avg_analyzer

Source
fn expand_avg_analyzer(
    plan: LogicalPlan,
) -> Result<Transformed<LogicalPlan>, DataFusionError>
Expand description

expand avg(<expr>) function into cast(sum((<expr>) AS f64)/count((<expr>)