Struct StreamingAggregateIterator 

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

Iterator that performs streaming aggregation over sorted input.

Implementations

impl<'a> StreamingAggregateIterator<'a>

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

Trait Implementations

impl<'a> RowIterator for StreamingAggregateIterator<'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.