Function datafusion::physical_expr::expressions::create_aggregate_expr

pub fn create_aggregate_expr(
    fun: &AggregateFunction,
    distinct: bool,
    input_phy_exprs: &[Arc<dyn PhysicalExpr>],
    ordering_req: &[PhysicalSortExpr],
    input_schema: &Schema,
    name: impl Into<String>,
    ignore_nulls: bool
) -> Result<Arc<dyn AggregateExpr>, DataFusionError>

Create a physical aggregation expression. This function errors when input_phy_exprs’ can’t be coerced to a valid argument type of the aggregation function.