Expand description
Shared windowed-aggregation engine: one schema-agnostic core behind both faces, the sdk drivers (static Row
output) and the flow Window/Aggregate operators (dynamic Columns/RowShape output).
Modules§
- accumulator
- coord
- engine
- Schema-agnostic windowing state-machine engines. An engine owns accumulator state, late
rejection, eviction and diff routing; the caller (the “face”) owns extraction and output
construction, handing over pre-bucketed events and translating
WindowResults into diffs. - kind
- meta
- mint
- span