See: Description
| Interface | Description |
|---|---|
| SideInputValues<T> |
SideInputValues serves as a Kryo serializable container that contains a materialized view
of side inputs. |
| SideInputValues.Loader<T> |
Factory function for load
SideInputValues from a Dataset. |
| Class | Description |
|---|---|
| CachedSideInputReader |
SideInputReader that caches results for costly
Materializations. |
| GroupAlsoByWindowViaOutputBufferFn<K,InputT,W extends BoundedWindow> |
A FlatMap function that groups by windows in batch mode using
ReduceFnRunner. |
| NoOpStepContext |
A
StepContext for Spark Batch Runner execution. |
| SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T> | |
| SideInputValues.ByWindow<T> |
General
SideInputValues for BoundedWindows in two possible
states. |
| SideInputValues.Global<T> |
Specialized
SideInputValues for use with the GlobalWindow in two possible
states. |
| SparkSideInputReader |
SideInputReader using broadcasted
SideInputValues. |