public abstract static class CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> extends java.lang.Object implements CombineWithContext.RequiresContextInternal
PipelineOptions
and side inputs through
CombineWithContext.Context
.
See the equivalent Combine.CombineFn
for details about combine functions.
Constructor and Description |
---|
CombineFnWithContext() |
Modifier and Type | Method and Description |
---|---|
abstract AccumT |
addInput(AccumT accumulator,
InputT input,
CombineWithContext.Context c)
Adds the given input value to the given accumulator, returning the
new accumulator value.
|
OutputT |
apply(java.lang.Iterable<? extends InputT> inputs,
CombineWithContext.Context c)
Applies this
CombineFnWithContext to a collection of input values to produce a
combined output value. |
AccumT |
compact(AccumT accumulator,
CombineWithContext.Context c)
Returns an accumulator that represents the same logical value as the
input accumulator, but may have a more compact representation.
|
abstract AccumT |
createAccumulator(CombineWithContext.Context c)
Returns a new, mutable accumulator value, representing the accumulation of zero input values.
|
OutputT |
defaultValue()
Returns the default value when there are no values added to the accumulator.
|
abstract OutputT |
extractOutput(AccumT accumulator,
CombineWithContext.Context c)
Returns the output value that is the result of combining all
the input values represented by the given accumulator.
|
java.lang.reflect.TypeVariable<?> |
getAccumTVariable()
Returns the
TypeVariable of AccumT . |
Coder<AccumT> |
getAccumulatorCoder(CoderRegistry registry,
Coder<InputT> inputCoder)
Returns the
Coder to use for accumulator AccumT
values, or null if it is not able to be inferred. |
Coder<OutputT> |
getDefaultOutputCoder(CoderRegistry registry,
Coder<InputT> inputCoder)
Returns the
Coder to use by default for output
OutputT values, or null if it is not able to be inferred. |
java.lang.String |
getIncompatibleGlobalWindowErrorMessage()
Returns the error message for not supported default values in Combine.globally().
|
java.lang.reflect.TypeVariable<?> |
getInputTVariable()
Returns the
TypeVariable of InputT . |
java.lang.reflect.TypeVariable<?> |
getOutputTVariable()
Returns the
TypeVariable of OutputT . |
abstract AccumT |
mergeAccumulators(java.lang.Iterable<AccumT> accumulators,
CombineWithContext.Context c)
Returns an accumulator representing the accumulation of all the
input values accumulated in the merging accumulators.
|
void |
populateDisplayData(DisplayData.Builder builder)
Register display data for the given transform or component.
|
public abstract AccumT createAccumulator(CombineWithContext.Context c)
It is equivalent to Combine.CombineFn.createAccumulator()
, but it has additional access to
CombineWithContext.Context
.
public abstract AccumT addInput(AccumT accumulator, InputT input, CombineWithContext.Context c)
It is equivalent to Combine.CombineFn.addInput(AccumT, InputT)
, but it has additional access to
CombineWithContext.Context
.
public abstract AccumT mergeAccumulators(java.lang.Iterable<AccumT> accumulators, CombineWithContext.Context c)
It is equivalent to Combine.CombineFn.mergeAccumulators(java.lang.Iterable<AccumT>)
, but it has additional access to
CombineWithContext.Context
.
public abstract OutputT extractOutput(AccumT accumulator, CombineWithContext.Context c)
It is equivalent to Combine.CombineFn.extractOutput(AccumT)
, but it has additional access to
CombineWithContext.Context
.
public AccumT compact(AccumT accumulator, CombineWithContext.Context c)
It is equivalent to Combine.CombineFn.compact(AccumT)
, but it has additional access to
CombineWithContext.Context
.
public OutputT apply(java.lang.Iterable<? extends InputT> inputs, CombineWithContext.Context c)
CombineFnWithContext
to a collection of input values to produce a
combined output value.public OutputT defaultValue()
CombineFnBase.GlobalCombineFn
defaultValue
in interface CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>
public Coder<AccumT> getAccumulatorCoder(CoderRegistry registry, Coder<InputT> inputCoder) throws CannotProvideCoderException
CombineFnBase.GlobalCombineFn
Coder
to use for accumulator AccumT
values, or null if it is not able to be inferred.
By default, uses the knowledge of the Coder
being used
for InputT
values and the enclosing Pipeline
's
CoderRegistry
to try to infer the Coder for AccumT
values.
This is the Coder used to send data through a communication-intensive shuffle step, so a compact and efficient representation may have significant performance benefits.
getAccumulatorCoder
in interface CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>
CannotProvideCoderException
public Coder<OutputT> getDefaultOutputCoder(CoderRegistry registry, Coder<InputT> inputCoder) throws CannotProvideCoderException
CombineFnBase.GlobalCombineFn
Coder
to use by default for output
OutputT
values, or null if it is not able to be inferred.
By default, uses the knowledge of the Coder
being
used for input InputT
values and the enclosing
Pipeline
's CoderRegistry
to try to infer the
Coder for OutputT
values.
getDefaultOutputCoder
in interface CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>
CannotProvideCoderException
public java.lang.String getIncompatibleGlobalWindowErrorMessage()
CombineFnBase.GlobalCombineFn
getIncompatibleGlobalWindowErrorMessage
in interface CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>
public java.lang.reflect.TypeVariable<?> getInputTVariable()
TypeVariable
of InputT
.public java.lang.reflect.TypeVariable<?> getAccumTVariable()
TypeVariable
of AccumT
.public java.lang.reflect.TypeVariable<?> getOutputTVariable()
TypeVariable
of OutputT
.public void populateDisplayData(DisplayData.Builder builder)
populateDisplayData(DisplayData.Builder)
is invoked by Pipeline runners to collect
display data via DisplayData.from(HasDisplayData)
. Implementations may call
super.populateDisplayData(builder)
in order to register display data in the current
namespace, but should otherwise use subcomponent.populateDisplayData(builder)
to use
the namespace of the subcomponent.
By default, does not register any display data. Implementors may override this method to provide their own display data.
populateDisplayData
in interface HasDisplayData
builder
- The builder to populate with display data.HasDisplayData