Package org.apache.beam.sdk.util

Class AppliedCombineFn<K,InputT,AccumT,OutputT>

java.lang.Object

org.apache.beam.sdk.util.AppliedCombineFn<K,InputT,AccumT,OutputT>

Type Parameters:

K - type of keys

InputT - type of input values

AccumT - type of mutable accumulator values

OutputT - type of output values

All Implemented Interfaces:

java.io.Serializable

@Internal
public class AppliedCombineFn<K,InputT,AccumT,OutputT>
extends java.lang.Object
implements java.io.Serializable

A CombineFnBase.GlobalCombineFn with a fixed accumulator coder. This is created from a specific application of the CombineFnBase.GlobalCombineFn.

Because the AccumT may reference InputT, the specific Coder<AccumT> may depend on the Coder<InputT>.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
Coder<AccumT>	getAccumulatorCoder()
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>	getFn()
KvCoder<K,InputT>	getKvCoder()
java.lang.Iterable<PCollectionView<?>>	getSideInputViews()
WindowingStrategy<?,?>	getWindowingStrategy()
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn, Coder<AccumT> accumCoder)
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn, Coder<AccumT> accumCoder, java.lang.Iterable<PCollectionView<?>> sideInputViews, KvCoder<K,InputT> kvCoder, WindowingStrategy<?,?> windowingStrategy)
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withInputCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn, CoderRegistry registry, KvCoder<K,InputT> kvCoder)
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withInputCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn, CoderRegistry registry, KvCoder<K,InputT> kvCoder, java.lang.Iterable<PCollectionView<?>> sideInputViews, WindowingStrategy<?,?> windowingStrategy)

Methods inherited from class java.lang.Object

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

Method Detail

withAccumulatorCoder

public static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT> withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
                                                                                                                                           Coder<AccumT> accumCoder)

withAccumulatorCoder

public static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT> withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
                                                                                                                                           Coder<AccumT> accumCoder,
                                                                                                                                           java.lang.Iterable<PCollectionView<?>> sideInputViews,
                                                                                                                                           KvCoder<K,InputT> kvCoder,
                                                                                                                                           WindowingStrategy<?,?> windowingStrategy)

withInputCoder

public static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT> withInputCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
                                                                                                                                     CoderRegistry registry,
                                                                                                                                     KvCoder<K,InputT> kvCoder)

withInputCoder

public static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT> withInputCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
                                                                                                                                     CoderRegistry registry,
                                                                                                                                     KvCoder<K,InputT> kvCoder,
                                                                                                                                     java.lang.Iterable<PCollectionView<?>> sideInputViews,
                                                                                                                                     WindowingStrategy<?,?> windowingStrategy)

getFn

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

getSideInputViews

public java.lang.Iterable<PCollectionView<?>> getSideInputViews()

getAccumulatorCoder

public Coder<AccumT> getAccumulatorCoder()

getKvCoder

public KvCoder<K,InputT> getKvCoder()

getWindowingStrategy

public WindowingStrategy<?,?> getWindowingStrategy()