| Class | Description |
|---|---|
| SparkGroupAlsoByWindowViaWindowSet |
An implementation of
GroupAlsoByWindowViaWindowSetDoFn
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. |