datafusion_physical_plan::aggregates

Function aggregate_expressions

Source
pub fn aggregate_expressions(
    aggr_expr: &[Arc<AggregateFunctionExpr>],
    mode: &AggregateMode,
    col_idx_base: usize,
) -> Result<Vec<Vec<Arc<dyn PhysicalExpr>>>>
Expand description

Returns physical expressions for arguments to evaluate against a batch.

The expressions are different depending on mode:

  • Partial: AggregateFunctionExpr::expressions
  • Final: columns of AggregateFunctionExpr::state_fields()