pub fn create_aggregate_expr_with_dfschema(
    fun: &AggregateUDF,
    input_phy_exprs: &[Arc<dyn PhysicalExpr>],
    input_exprs: &[Expr],
    sort_exprs: &[Expr],
    ordering_req: &[PhysicalSortExpr],
    dfschema: &DFSchema,
    alias: Option<String>,
    ignore_nulls: bool,
    is_distinct: bool,
    is_reversed: bool,
) -> Result<Arc<dyn AggregateExpr>>