datafusion::physical_plan::aggregates

Function finalize_aggregation

Source
pub fn finalize_aggregation(
    accumulators: &mut [Box<dyn Accumulator>],
    mode: &AggregateMode,
) -> Result<Vec<Arc<dyn Array>>, DataFusionError>
Expand description

returns a vector of ArrayRefs, where each entry corresponds to either the final value (mode = Final, FinalPartitioned and Single) or states (mode = Partial)