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

Class AbstractFlinkCombineRunner.FinalFlinkCombiner<K,AccumT,OutputT>

java.lang.Object

org.apache.beam.runners.flink.translation.functions.AbstractFlinkCombineRunner.FinalFlinkCombiner<K,AccumT,OutputT>

All Implemented Interfaces:

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

Enclosing class:

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

public static class AbstractFlinkCombineRunner.FinalFlinkCombiner<K,AccumT,OutputT>
extends Object
implements AbstractFlinkCombineRunner.FlinkCombiner<K,AccumT,AccumT,OutputT>

A final combiner that takes in AccumT and produces OutputT.

Constructor Summary

Constructors

Constructor	Description
FinalFlinkCombiner(CombineFnBase.GlobalCombineFn<?,AccumT,OutputT> combineFn)

Method Summary

Modifier and Type	Method	Description
AccumT	addInput(K key, AccumT accumulator, AccumT 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, AccumT value, PipelineOptions options, org.apache.beam.runners.core.SideInputReader sideInputReader, Collection<? extends BoundedWindow> windows)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FinalFlinkCombiner

public FinalFlinkCombiner(CombineFnBase.GlobalCombineFn<?,AccumT,OutputT> combineFn)

Method Details

firstInput

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

Specified by:

firstInput in interface AbstractFlinkCombineRunner.FlinkCombiner<K,AccumT,AccumT,OutputT>

addInput

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

Specified by:

addInput in interface AbstractFlinkCombineRunner.FlinkCombiner<K,AccumT,AccumT,OutputT>

extractOutput

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

Specified by:

extractOutput in interface AbstractFlinkCombineRunner.FlinkCombiner<K,AccumT,AccumT,OutputT>