Package org.apache.beam.sdk.util
Class CombineFnUtil
- java.lang.Object
-
- org.apache.beam.sdk.util.CombineFnUtil
-
@Internal public class CombineFnUtil extends java.lang.Object
Static utility methods that create combine function instances.
-
-
Constructor Summary
Constructors Constructor Description CombineFnUtil()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <K,InputT,AccumT,OutputT>
Combine.CombineFn<InputT,AccumT,OutputT>bindContext(CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn, StateContext<?> stateContext)
Returns the partial application of theCombineWithContext.CombineFnWithContext
to a specific context to produce aCombine.CombineFn
.static <InputT,AccumT,OutputT>
CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT>toFnWithContext(CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> globalCombineFn)
Return aCombineWithContext.CombineFnWithContext
from the givenCombineFnBase.GlobalCombineFn
.
-
-
-
Method Detail
-
bindContext
public static <K,InputT,AccumT,OutputT> Combine.CombineFn<InputT,AccumT,OutputT> bindContext(CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> combineFn, StateContext<?> stateContext)
Returns the partial application of theCombineWithContext.CombineFnWithContext
to a specific context to produce aCombine.CombineFn
.The returned
Combine.CombineFn
cannot be serialized.
-
toFnWithContext
public static <InputT,AccumT,OutputT> CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> toFnWithContext(CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> globalCombineFn)
Return aCombineWithContext.CombineFnWithContext
from the givenCombineFnBase.GlobalCombineFn
.
-
-