Struct HashAggregateNode 

pub struct HashAggregateNode { /* private fields */ }

Hash aggregate operator.

Materializes all input, groups by key expressions, computes aggregates, then emits one row per group.

HashAggregate(group_by=[dept], aggs=[COUNT(*), AVG(salary)])
  └── input

Implementations

impl HashAggregateNode

pub fn new( input: Box<dyn PlanNode>, group_by_exprs: Vec<Expr>, agg_defs: Vec<AggDef>, ) -> Self

Trait Implementations

impl PlanNode for HashAggregateNode

fn schema(&self) -> &Schema

Schema of rows produced by this node.

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

Return the next row, or None when exhausted.

fn reset(&mut self) -> Result<()>

Reset the operator for re-execution (e.g., inner side of nested loop join).

fn collect_all(&mut self) -> Result<Vec<Row>>

Collect all remaining rows (convenience method).