Struct ExternalAggregate 

pub struct ExternalAggregate { /* private fields */ }

External aggregate operator

Implements memory-bounded aggregation with disk spilling.

Implementations

impl ExternalAggregate

pub fn new( controller: &Arc<MemoryController>, num_key_columns: usize, aggregate_specs: Vec<AggregateSpec>, ) -> Self

Create a new external aggregate operator

pub fn with_config( controller: &Arc<MemoryController>, num_key_columns: usize, aggregate_specs: Vec<AggregateSpec>, config: ExternalAggregateConfig, ) -> Self

Create with custom configuration

pub fn add_row(&mut self, row: &[SqlValue]) -> Result<()>

Add a row to the aggregate

The row should have the group key columns first, followed by the aggregate value columns.

pub fn finish(self) -> Result<AggregateResultIterator>

Finish aggregation and return results iterator

pub fn num_groups(&self) -> usize

Get the number of groups

pub fn num_spilled_partitions(&self) -> usize

Get the number of spilled partitions