See: Description
| Class | Description |
|---|---|
| ByteArray |
Serializable byte array.
|
| GlobalWatermarkHolder |
A
BlockStore variable to hold the global watermarks for a micro-batch. |
| GlobalWatermarkHolder.SparkWatermarks |
A
GlobalWatermarkHolder.SparkWatermarks holds the watermarks and batch time
relevant to a micro-batch input from a specific source. |
| GlobalWatermarkHolder.WatermarkAdvancingStreamingListener |
Advance the WMs onBatchCompleted event.
|
| SideInputBroadcast<T> |
Broadcast helper for side inputs.
|
| SparkSideInputReader |
A
SideInputReader for thw SparkRunner. |