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

Class AbstractFlinkCombineRunner.CompleteFlinkCombiner<K,InputT,AccumT,OutputT>

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

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

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

A straight wrapper of CombineFnBase.GlobalCombineFn that takes in InputT and emits OutputT.

Constructor Summary

Constructors

Constructor	Description
CompleteFlinkCombiner(CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> combineFn)

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)

Methods inherited from class java.lang.Object

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

Constructor Details

CompleteFlinkCombiner

public CompleteFlinkCombiner(CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> combineFn)

Method Details

firstInput

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

Specified by:

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

addInput

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

Specified by:

addInput in interface AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,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,InputT,AccumT,OutputT>