Function datafusion::physical_plan::udaf::create_aggregate_expr

pub fn create_aggregate_expr(
    fun: &AggregateUDF,
    input_phy_exprs: &[Arc<dyn PhysicalExpr>],
    sort_exprs: &[Expr],
    ordering_req: &[PhysicalSortExpr],
    schema: &Schema,
    name: impl Into<String>,
    ignore_nulls: bool,
    is_distinct: bool,
) -> Result<Arc<dyn AggregateExpr>, DataFusionError>

Creates a physical expression of the UDAF, that includes all necessary type coercion. This function errors when args’ can’t be coerced to a valid argument type of the UDAF.