Struct AggregateIterator 

pub struct AggregateIterator<'a> { /* private fields */ }

Iterator that performs hash-based aggregation over input rows.

Implementations

impl<'a> AggregateIterator<'a>

pub fn new( input: Box<dyn RowIterator + 'a>, group_keys: Vec<TypedExpr>, aggregates: Vec<AggregateExpr>, having: Option<TypedExpr>, schema: Vec<ColumnMetadata>, ) -> Self

Create a new aggregate iterator with the default group limit.

pub fn with_group_limit(self, limit: usize) -> Self

Override the maximum number of groups allowed during aggregation.

pub fn with_memory_policy(self, policy: Option<MemoryPolicy>) -> Self

Attach a memory policy for enforcing in-flight aggregation limits.

Trait Implementations

impl<'a> RowIterator for AggregateIterator<'a>

fn next_row(&mut self) -> Option<Result<Row>>

Advances the iterator and returns the next row, or None if exhausted.

fn schema(&self) -> &[ColumnMetadata]

Returns the schema of rows produced by this iterator.