Package org.apache.beam.sdk.transforms
Class CombineFns.ComposeCombineFnBuilder
- java.lang.Object
-
- org.apache.beam.sdk.transforms.CombineFns.ComposeCombineFnBuilder
-
- Enclosing class:
- CombineFns
public static class CombineFns.ComposeCombineFnBuilder extends java.lang.Object
A builder class to construct a composedCombineFnBase.GlobalCombineFn
.
-
-
Constructor Summary
Constructors Constructor Description ComposeCombineFnBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <DataT,InputT,OutputT>
CombineFns.ComposedCombineFn<DataT>with(SimpleFunction<DataT,InputT> extractInputFn, Coder combineInputCoder, Combine.CombineFn<InputT,?,OutputT> combineFn, TupleTag<OutputT> outputTag)
Likewith(SimpleFunction, CombineFn, TupleTag)
but with an explicit input coder.<DataT,InputT,OutputT>
CombineFns.ComposedCombineFnWithContext<DataT>with(SimpleFunction<DataT,InputT> extractInputFn, Coder combineInputCoder, CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext, TupleTag<OutputT> outputTag)
Likewith(SimpleFunction, CombineFnWithContext, TupleTag)
but with input coder.<DataT,InputT,OutputT>
CombineFns.ComposedCombineFn<DataT>with(SimpleFunction<DataT,InputT> extractInputFn, Combine.CombineFn<InputT,?,OutputT> combineFn, TupleTag<OutputT> outputTag)
Returns aCombineFns.ComposedCombineFn
that can take additionalGlobalCombineFns
and apply them as a single combine function.<DataT,InputT,OutputT>
CombineFns.ComposedCombineFnWithContext<DataT>with(SimpleFunction<DataT,InputT> extractInputFn, CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext, TupleTag<OutputT> outputTag)
Returns aCombineFns.ComposedCombineFnWithContext
that can take additionalGlobalCombineFns
and apply them as a single combine function.
-
-
-
Method Detail
-
with
public <DataT,InputT,OutputT> CombineFns.ComposedCombineFn<DataT> with(SimpleFunction<DataT,InputT> extractInputFn, Combine.CombineFn<InputT,?,OutputT> combineFn, TupleTag<OutputT> outputTag)
Returns aCombineFns.ComposedCombineFn
that can take additionalGlobalCombineFns
and apply them as a single combine function.The
CombineFns.ComposedCombineFn
extracts inputs fromDataT
with theextractInputFn
and combines them with thecombineFn
, and then it outputs each combined value with aTupleTag
to aCombineFns.CoCombineResult
.
-
with
public <DataT,InputT,OutputT> CombineFns.ComposedCombineFn<DataT> with(SimpleFunction<DataT,InputT> extractInputFn, Coder combineInputCoder, Combine.CombineFn<InputT,?,OutputT> combineFn, TupleTag<OutputT> outputTag)
Likewith(SimpleFunction, CombineFn, TupleTag)
but with an explicit input coder.
-
with
public <DataT,InputT,OutputT> CombineFns.ComposedCombineFnWithContext<DataT> with(SimpleFunction<DataT,InputT> extractInputFn, CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext, TupleTag<OutputT> outputTag)
Returns aCombineFns.ComposedCombineFnWithContext
that can take additionalGlobalCombineFns
and apply them as a single combine function.The
CombineFns.ComposedCombineFnWithContext
extracts inputs fromDataT
with theextractInputFn
and combines them with thecombineFnWithContext
, and then it outputs each combined value with aTupleTag
to aCombineFns.CoCombineResult
.
-
with
public <DataT,InputT,OutputT> CombineFns.ComposedCombineFnWithContext<DataT> with(SimpleFunction<DataT,InputT> extractInputFn, Coder combineInputCoder, CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext, TupleTag<OutputT> outputTag)
Likewith(SimpleFunction, CombineFnWithContext, TupleTag)
but with input coder.
-
-