Crate llkv_aggregate 

Runtime aggregation utilities used by the planner and executor.

The crate evaluates logical aggregates described by llkv_plan::AggregateExpr against Arrow batches. It supports streaming accumulation with overflow checks and COUNT DISTINCT tracking for a subset of scalar types.

Structs

AggregateSpec

Specification for an aggregate operation.

AggregateState

Runtime state for an aggregate computation.

Enums

AggregateAccumulator

Accumulator for incremental aggregate computation.

AggregateExpr

Aggregate expression in SELECT.

AggregateFunction

Supported aggregate functions.

AggregateKind

Type of aggregate operation.

DistinctKey

Type Aliases

AggregateResult

Result type alias for aggregation routines.