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).

build_aggregate_schema: Build output schema for aggregate results.
build_partial_aggregate_schema: Build internal partial aggregate schema.
create_accumulator: Create a new accumulator instance for the aggregate function.
encode_group_key: Encode group key values into a deterministic byte sequence.
exact_partial_aggregate_is_proven: Returns whether an aggregate’s partial state can be merged without changing the current local SQL result. Floating-point, DISTINCT, and order-sensitive aggregates must instead be replayed from ordered inputs.
execute_parallel_aggregate_rows: Execute a deterministic single-process parallel partial-to-final aggregate.
execute_parallel_aggregate_rows_with_policy: Execute a deterministic parallel aggregate with memory fallback controls.
merge_exact_aggregate_states: Merge only aggregate states whose merge rule is proven to preserve the current local SQL result. This is the coordinator-side kernel used by the distributed result assembler after every worker has acknowledged cleanup.
should_use_single_for_parallel: Return true when aggregate execution must remain Single for correctness.