Function datafusion::physical_plan::udaf::create_aggregate_expr
source · 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
) -> Result<Arc<dyn AggregateExpr>, DataFusionError>
Expand description
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.