| AbstractDoFnTransform<InputT,InterT,OutputT> |
This is a base class for Beam DoFn Transforms.
|
| CombineFnFinalTransform<K,A,O> |
Accumulates all of the partially accumulated KVs(Key, Accum) into KVs(Key, Output).
|
| CombineFnPartialTransform<K,I,A> |
Partially accumulates the given KVs(Key, Input) into KVs(Key, Accum).
|
| CreateViewTransform<I,O> |
This transforms emits materialized data for each window.
|
| CreateViewTransform.MultiView<T> |
Represents PrimitiveViewT supplied to the ViewFn.
|
| DefaultOutputManager<OutputT> |
Default output emitter that uses outputCollector.
|
| DoFnTransform<InputT,OutputT> |
DoFn transform implementation when there is no side input.
|
| FinalCombineFn<AccumT,Output> |
Wrapper class for Combine.CombineFn.
|
| FlattenTransform<T> |
Flatten transform implementation.
|
| GBKTransform<K,InputT,OutputT> |
This transform executes GroupByKey transformation and CombinePerKey transformation when input data is unbounded
or is not in a global window.
|
| GroupByKeyTransform<I> |
Group Beam KVs.
|
| InMemoryStateInternalsFactory<K> |
InMemoryStateInternalsFactory.
|
| InMemoryTimerInternalsFactory<K> |
InMemoryTimerInternalsFactory.
|
| LoopCompositeTransform<inputT extends org.apache.beam.sdk.values.PInput,outputT extends org.apache.beam.sdk.values.POutput> |
A composite transform for wrapping transforms inside a loop to create loop operators in the IR.
|
| PartialCombineFn<InputT,AccumT> |
Wrapper class for Combine.CombineFn.
|
| PushBackDoFnTransform<InputT,OutputT> |
DoFn transform implementation with push backs for side inputs.
|
| SideInputTransform<T> |
Side input transform implementation.
|
| WindowFnTransform<T,W extends org.apache.beam.sdk.transforms.windowing.BoundedWindow> |
Windowing transform implementation.
|