com.google.cloud.dataflow.sdk.util

Class AppliedCombineFn<K,InputT,AccumT,OutputT>

java.lang.Object

com.google.cloud.dataflow.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:

Serializable

public class AppliedCombineFn<K,InputT,AccumT,OutputT>
extends Object
implements Serializable

A Combine.KeyedCombineFn with a fixed accumulator coder. This is created from a specific application of the Combine.KeyedCombineFn.

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 and Description
Coder<AccumT>	getAccumulatorCoder()
Combine.KeyedCombineFn<K,InputT,AccumT,OutputT>	getFn()
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withAccumulatorCoder(Combine.KeyedCombineFn<? super K,? super InputT,AccumT,OutputT> fn, Coder<AccumT> accumCoder)
static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT>	withInputCoder(Combine.KeyedCombineFn<? super K,? super InputT,AccumT,OutputT> fn, CoderRegistry registry, KvCoder<K,InputT> kvCoder)

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(Combine.KeyedCombineFn<? super K,? super InputT,AccumT,OutputT> fn,
                                                                                                       Coder<AccumT> accumCoder)

withInputCoder

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

getFn

public Combine.KeyedCombineFn<K,InputT,AccumT,OutputT> getFn()

getAccumulatorCoder

public Coder<AccumT> getAccumulatorCoder()