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

Class FlinkNonMergingReduceFunction<K,InputT>

java.lang.Object

org.apache.beam.runners.flink.translation.functions.FlinkNonMergingReduceFunction<K,InputT>

Type Parameters:

K - Key type.

InputT - Input type.

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.GroupReduceFunction<WindowedValue<KV<K,InputT>>,WindowedValue<KV<K,Iterable<InputT>>>>

public class FlinkNonMergingReduceFunction<K,InputT>
extends Object
implements org.apache.flink.api.common.functions.GroupReduceFunction<WindowedValue<KV<K,InputT>>,WindowedValue<KV<K,Iterable<InputT>>>>

Reduce function for non-merging GBK implementation. Implementation tries to return non-iterable results when possible, so we do not have to materialize all values for a single key in memory.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkNonMergingReduceFunction(WindowingStrategy<?,?> windowingStrategy, boolean reIterableResult)

Method Summary

Modifier and Type	Method	Description
void	reduce(Iterable<WindowedValue<KV<K,InputT>>> input, org.apache.flink.util.Collector<WindowedValue<KV<K,Iterable<InputT>>>> coll)

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkNonMergingReduceFunction

public FlinkNonMergingReduceFunction(WindowingStrategy<?,?> windowingStrategy,
 boolean reIterableResult)

Method Details

reduce

public void reduce(Iterable<WindowedValue<KV<K,InputT>>> input,
 org.apache.flink.util.Collector<WindowedValue<KV<K,Iterable<InputT>>>> coll)

Specified by:

reduce in interface org.apache.flink.api.common.functions.GroupReduceFunction<K,InputT>