| Class | Description |
|---|---|
| AggregateWindowState | |
| AggregationState<InputType> | |
| SliceManager<InputType> | |
| SlicingWindowOperator<InputType> |
Implementation of the slicing window operator based on the Scotty technique:
Scotty: Efficient AbstractWindow Aggregation for out-of-order Stream Processing:
Jonas Traub, Philipp M.
|
| StreamSlicer | |
| WindowManager |