Package org.apache.beam.runners.flink.translation.wrappers.streaming

package org.apache.beam.runners.flink.translation.wrappers.streaming

Internal implementation of the Beam runner for Apache Flink.

Related Packages

Package	Description
org.apache.beam.runners.flink.translation.wrappers	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.io	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.stableinput	Classes for buffering elements for achieving @RequiresStableInput.
org.apache.beam.runners.flink.translation.wrappers.streaming.state	Internal state implementation of the Beam runner for Apache Flink.

Classes

Class	Description
DoFnOperator<PreInputT,InputT,OutputT>	Flink operator for executing DoFns.
DoFnOperator.BufferedOutputManager<OutputT>	A WindowedValueReceiver that can buffer its outputs.
DoFnOperator.MultiOutputOutputManagerFactory<OutputT>	Implementation of DoFnOperator.OutputManagerFactory that creates an DoFnOperator.BufferedOutputManager that can write to multiple logical outputs by Flink side output.
ExecutableStageDoFnOperator<InputT,OutputT>	This operator is the streaming equivalent of the FlinkExecutableStageFunction.
FlinkKeyUtils	Utility functions for dealing with key encoding.
KvToFlinkKeyKeySelector<K,V>	KeySelector that retrieves a key from a KV.
PartialReduceBundleOperator<K,InputT,OutputT,AccumT>
SdfFlinkKeyKeySelector<K,V>	KeySelector that retrieves a key from a KV<KV<element, KV<restriction, watermarkState>>, size>.
SingletonKeyedWorkItem<K,ElemT>	Singleton keyed word item.
SingletonKeyedWorkItemCoder<K,ElemT>	Singleton keyed work item coder.
SplittableDoFnOperator<InputT,OutputT,RestrictionT>	Flink operator for executing splittable DoFns.
WindowDoFnOperator<K,InputT,OutputT>	Flink operator for executing window DoFns.
WorkItemKeySelector<K,V>	KeySelector that retrieves a key from a KeyedWorkItem.