Module window_sort 

Window-Local Sort Operator

ORDER BY within windowed aggregations. Bounded by window size.

Sits downstream of a window operator. Buffers output events per window. On watermark advance past window end, sorts the buffer and emits. Optionally applies a LIMIT for top-N within each window.

Memory Bounds

Memory is bounded by the maximum number of events per window. Each window buffer is released immediately after sorting and emission.

Structs

WindowLocalSortOperator

Window-local sort operator.