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

Class SingleWindowFlinkCombineRunner<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.SingleWindowFlinkCombineRunner<K,InputT,AccumT,OutputT,W>

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

A Flink combine runner takes elements pre-grouped by window and produces output after seeing all input.

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
SingleWindowFlinkCombineRunner()

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

SingleWindowFlinkCombineRunner

public SingleWindowFlinkCombineRunner()

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)

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>