aggregate_batch

datafusion_physical_plan::aggregates::no_grouping

Function aggregate_batch 

Source 
fn aggregate_batch(
    mode: &AggregateMode,
    batch: RecordBatch,
    accumulators: &mut [AccumulatorItem],
    expressions: &[Vec<Arc<dyn PhysicalExpr>>],
    filters: &[Option<Arc<dyn PhysicalExpr>>],
) -> Result<usize>
Expand description

Perform group-by aggregation for the given [RecordBatch].

If successful, this returns the additional number of bytes that were allocated during this process.

TODO: Make this a member function