See: Description
| Class | Description |
|---|---|
| ByteArray |
Serializable byte array.
|
| CachedSideInputReader |
SideInputReader that caches materialized views. |
| 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.
|
| SparkCommon |
Common methods to build Spark specific objects used by different runners.
|
| SparkCompat |
A set of functions to provide API compatibility between Spark 2 and Spark 3.
|
| SparkSideInputReader |
A
SideInputReader for the SparkRunner. |
| TimerUtils |