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

Class HashingFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>

java.lang.Object

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

org.apache.beam.runners.flink.translation.functions.HashingFlinkCombineRunner<K,InputT,AccumT,OutputT,W>

public class HashingFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>
extends AbstractFlinkCombineRunner<K,InputT,AccumT,OutputT,W>

A Flink combine runner that builds a map of merged windows and produces output after seeing all input. This is similar to whatReduceFnRunner does.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.runners.flink.translation.functions.AbstractFlinkCombineRunner

AbstractFlinkCombineRunner.CompleteFlinkCombiner<K,InputT,AccumT,OutputT>, AbstractFlinkCombineRunner.FinalFlinkCombiner<K,AccumT,OutputT>, AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,AccumT,OutputT>, AbstractFlinkCombineRunner.PartialFlinkCombiner<K,InputT,AccumT>

Constructor Summary

Constructors

Constructor	Description
HashingFlinkCombineRunner()

Method Summary

Modifier and Type	Method	Description
void	combine(AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,AccumT,OutputT> flinkCombiner, WindowingStrategy<Object,W> windowingStrategy, org.apache.beam.runners.core.SideInputReader sideInputReader, PipelineOptions options, Iterable<WindowedValue<KV<K,InputT>>> elements, org.apache.flink.util.Collector<WindowedValue<KV<K,OutputT>>> out)	Consumes WindowedValues and produces combined output to the given output.

Methods inherited from class java.lang.Object

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

Constructor Details

HashingFlinkCombineRunner

public HashingFlinkCombineRunner()

Method Details

combine

public void combine(AbstractFlinkCombineRunner.FlinkCombiner<K,InputT,AccumT,OutputT> flinkCombiner,
 WindowingStrategy<Object,W> windowingStrategy,
 org.apache.beam.runners.core.SideInputReader sideInputReader,
 PipelineOptions options,
 Iterable<WindowedValue<KV<K,InputT>>> elements,
 org.apache.flink.util.Collector<WindowedValue<KV<K,OutputT>>> out)
             throws Exception

Description copied from class: AbstractFlinkCombineRunner

Consumes WindowedValues and produces combined output to the given output.

Specified by:

combine in class AbstractFlinkCombineRunner<K,InputT,AccumT,OutputT,W extends BoundedWindow>

Throws:

Exception