Package org.apache.beam.runners.flink.translation.functions

package org.apache.beam.runners.flink.translation.functions

Internal implementation of the Beam runner for Apache Flink.

Class	Description
AbstractFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>	Abstract base for runners that execute a Combine.PerKey.
AbstractFlinkCombineRunner.CompleteFlinkCombiner<K,InputT,AccumT,OutputT>	A straight wrapper of CombineFnBase.GlobalCombineFn that takes in InputT and emits OutputT.
AbstractFlinkCombineRunner.FinalFlinkCombiner<K,AccumT,OutputT>	A final combiner that takes in AccumT and produces OutputT.
AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,AccumT,OutputT>	Adapter interface that allows using a CombineFnBase.GlobalCombineFn to either produce the AccumT as output or to combine several accumulators into an OutputT.
AbstractFlinkCombineRunner.PartialFlinkCombiner<K,InputT,AccumT>	A partial combiner that takes in InputT and produces AccumT.
FlinkAssignWindows<T,W extends BoundedWindow>	Flink FlatMapFunction for implementing Window.Assign.
FlinkDoFnFunction<InputT,OutputT>	Encapsulates a DoFn inside a Flink RichMapPartitionFunction.
FlinkExecutableStageContextFactory	Singleton class that contains one ExecutableStageContext.Factory per job.
FlinkExecutableStageFunction<InputT>	Flink operator that passes its input DataSet through an SDK-executed ExecutableStage.
FlinkExecutableStagePruningFunction	A Flink function that demultiplexes output from a FlinkExecutableStageFunction.
FlinkExplodeWindowsFunction<T>	Explode WindowedValue that belongs to multiple windows into multiple "single window" values, so we can safely group elements by (K, W) tuples.
FlinkIdentityFunction<T>	A map function that outputs the input element without any change.
FlinkMergingNonShuffleReduceFunction<K,InputT,AccumT,OutputT,W extends BoundedWindow>	Special version of FlinkReduceFunction that supports merging windows.
FlinkMultiOutputPruningFunction<T>	A FlatMapFunction function that filters out those elements that don't belong in this output.
FlinkNonMergingReduceFunction<K,InputT>	Reduce function for non-merging GBK implementation.
FlinkNoOpStepContext	A StepContext for Flink Batch Runner execution.
FlinkPartialReduceFunction<K,InputT,AccumT,W extends BoundedWindow>	This is the first step for executing a Combine.PerKey on Flink.
FlinkReduceFunction<K,AccumT,OutputT,W extends BoundedWindow>	This is the second part for executing a Combine.PerKey on Flink, the second part is FlinkReduceFunction.
FlinkSideInputReader	A SideInputReader for the Flink Batch Runner.
FlinkStatefulDoFnFunction<K,V,OutputT>	A RichGroupReduceFunction for stateful ParDo in Flink Batch Runner.
HashingFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>	A Flink combine runner that builds a map of merged windows and produces output after seeing all input.
ImpulseSourceFunction	Source function which sends a single global impulse to a downstream operator.
SideInputInitializer<ViewT>	BroadcastVariableInitializer that initializes the broadcast input as a Map from window to side input.
SingleWindowFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>	A Flink combine runner takes elements pre-grouped by window and produces output after seeing all input.
SortingFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>	A Flink combine runner that first sorts the elements by window and then does one pass that merges windows and outputs results.