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