See: Description
| Class | Description |
|---|---|
| ByteArray |
Serializable byte array.
|
| GlobalWatermarkHolder |
A store 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 the SparkRunner. |