See: Description
| Class | Description |
|---|---|
| AssignWindowsFunction<T> |
Assign Windows function.
|
| ByteToElemFunction<V> |
ByteToWindow function.
|
| ByteToWindowFunction<K,V> |
ByteToWindow function.
|
| ByteToWindowFunctionPrimitive<K,V> |
ByteToWindow function.
|
| DoFnFunction<OutputT,InputT> |
DoFn function.
|
| ElemToBytesFunction<V> |
Map to tuple function.
|
| GroupByWindowFunction<K,V,W extends BoundedWindow> |
GroupBy window function.
|
| ImpulseSource |
A
SourceFunc which executes the impulse transform contract. |
| MapToTupleFunction<K,V> |
Map to tuple function.
|
| OutputTagFilter<OutputT,InputT> |
Output tag filter.
|
| Twister2SinkFunction<T> |
Sink Function that collects results.
|