Skip to main content

Module aggregate

linkrs_query::executor::streaming::operators::blocking

Module aggregate 

Source

Structs§

AggregateState
FinalAggregateState
GroupByState
PartialAggregateState

Constants§

ACCUMULATOR_OVERHEAD_BYTES
Estimated in-memory overhead of one AggregateAccumulator instance (enum tag plus internal state) used for memory accounting. Charged once per aggregate function per group so workloads with many small keys are accounted for beyond the group key itself.