Module row_hash 

Hash aggregation

Structs

GroupedHashAggregateStream 🔒

HashTable based Grouping Aggregator

SkipAggregationProbe 🔒

Tracks if the aggregate should skip partial aggregations

SpillState 🔒

This encapsulates the spilling state

Enums

ExecutionState 🔒

This object tracks the aggregation phase (input/output)

Functions

create_group_accumulator 🔒

Create an accumulator for agg_expr – a [GroupsAccumulator] if that is supported by the aggregate, or a GroupsAccumulatorAdapter if not.