K
- type of keysInputT
- type of input valuesAccumT
- type of mutable accumulator valuesOutputT
- type of output values@Internal public class AppliedCombineFn<K,InputT,AccumT,OutputT> extends java.lang.Object implements java.io.Serializable
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>
.
Modifier and Type | Method and 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> |
withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
Coder<AccumT> accumCoder) |
static <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> |
withInputCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn,
CoderRegistry registry,
KvCoder<K,InputT> kvCoder) |
static <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) |
public static <K,InputT,AccumT,OutputT> AppliedCombineFn<K,InputT,AccumT,OutputT> withAccumulatorCoder(CombineFnBase.GlobalCombineFn<? super InputT,AccumT,OutputT> fn, Coder<AccumT> accumCoder)
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)
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)
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)
public CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> getFn()
public java.lang.Iterable<PCollectionView<?>> getSideInputViews()
public WindowingStrategy<?,?> getWindowingStrategy()