| Class | Description |
|---|---|
| SparkGroupAlsoByWindowViaWindowSet |
An implementation of
GroupByKeyViaGroupByKeyOnly.GroupAlsoByWindow logic for grouping by windows and controlling
trigger firings and pane accumulation. |
| SparkTimerInternals |
An implementation of
TimerInternals for the SparkRunner. |
| StateSpecFunctions |
A class containing
StateSpec mappingFunctions. |