Function deltalake::datafusion::physical_planner::create_aggregate_expr_with_name_and_maybe_filter
source · pub fn create_aggregate_expr_with_name_and_maybe_filter(
e: &Expr,
name: impl Into<String>,
logical_input_schema: &DFSchema,
physical_input_schema: &Schema,
execution_props: &ExecutionProps
) -> Result<(Arc<dyn AggregateExpr>, Option<Arc<dyn PhysicalExpr>>, Option<Vec<PhysicalSortExpr>>), DataFusionError>
Expand description
Create an aggregate expression with a name from a logical expression