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

Class AbstractFlinkCombineRunner.PartialFlinkCombiner<K,InputT,AccumT>

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

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

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

A partial combiner that takes in InputT and produces AccumT.

Constructor Summary

Constructors

Constructor	Description
PartialFlinkCombiner(CombineFnBase.GlobalCombineFn<InputT,AccumT,?> 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)
AccumT	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

PartialFlinkCombiner

public PartialFlinkCombiner(CombineFnBase.GlobalCombineFn<InputT,AccumT,?> 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,AccumT>

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,AccumT>

extractOutput

public AccumT 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,AccumT>