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

Interface AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,AccumT,OutputT>

All Known Implementing Classes:

AbstractFlinkCombineRunner.CompleteFlinkCombiner, AbstractFlinkCombineRunner.FinalFlinkCombiner, AbstractFlinkCombineRunner.PartialFlinkCombiner

Enclosing class:

AbstractFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>

public static interface 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. The former would be used for a partial combine while the latter is used for the final merging of accumulators.

Method Summary

Modifier and Type	Method	Description
AccumT	addInput(K key, AccumT accumulator, InputT value, PipelineOptions options, org.apache.beam.runners.core.SideInputReader sideInputReader, Collection<? extends BoundedWindow> windows)
OutputT	extractOutput(K key, AccumT accumulator, PipelineOptions options, org.apache.beam.runners.core.SideInputReader sideInputReader, Collection<? extends BoundedWindow> windows)
AccumT	firstInput(K key, InputT value, PipelineOptions options, org.apache.beam.runners.core.SideInputReader sideInputReader, Collection<? extends BoundedWindow> windows)

Method Details

firstInput

AccumT firstInput(K key,
 InputT value,
 PipelineOptions options,
 org.apache.beam.runners.core.SideInputReader sideInputReader,
 Collection<? extends BoundedWindow> windows)

addInput

AccumT addInput(K key,
 AccumT accumulator,
 InputT value,
 PipelineOptions options,
 org.apache.beam.runners.core.SideInputReader sideInputReader,
 Collection<? extends BoundedWindow> windows)

extractOutput

OutputT extractOutput(K key,
 AccumT accumulator,
 PipelineOptions options,
 org.apache.beam.runners.core.SideInputReader sideInputReader,
 Collection<? extends BoundedWindow> windows)