See: Description
| Class | Description |
|---|---|
| AssignWindowsFunction<T> |
Assign Windows function.
|
| ByteToWindowFunction<K,V> |
ByteToWindow function.
|
| DoFnFunction<OT,IT> |
DoFn function.
|
| GroupByWindowFunction<K,V,W extends BoundedWindow> |
GroupBy window function.
|
| MapToTupleFunction<K,V> |
Map to tuple function.
|
| OutputTagFilter<OT,IT> |
Output tag filter.
|
| SideInputSinkFunction<T,VT> |
Sink Function that collects results.
|
| Twister2SinkFunction<T> |
Sink Function that collects results.
|