Module aggregate 

Structs

AggregateIterator

Iterator that performs hash-based aggregation over input rows.

AvgAccumulator

Accumulator for AVG.

CountAccumulator

Accumulator for COUNT / COUNT(DISTINCT).

GroupConcatAccumulator

Accumulator for GROUP_CONCAT.

MinMaxAccumulator

Accumulator for MIN / MAX.

StreamingAggregateIterator

Iterator that performs streaming aggregation over sorted input.

StringAggAccumulator

Accumulator for STRING_AGG.

SumAccumulator

Accumulator for SUM.

TotalAccumulator

Accumulator for TOTAL (SUM that returns 0.0 on empty/all-NULL input).

Traits

Accumulator

Accumulator interface for aggregate function execution.

Functions

build_aggregate_schema

Build output schema for aggregate results.

create_accumulator

Create a new accumulator instance for the aggregate function.

encode_group_key

Encode group key values into a deterministic byte sequence.

Type Aliases

GroupKeyBytes

Byte-encoded group key for hash-based aggregation.