aggregate_expressions

Function aggregate_expressions 

Source
pub fn aggregate_expressions(
    aggr_expr: &[Arc<AggregateFunctionExpr>],
    mode: &AggregateMode,
    col_idx_base: usize,
) -> Result<Vec<Vec<Arc<dyn PhysicalExpr>>>, DataFusionError>
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()