Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.runners
Class AggregatorValues<T>
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.runners.AggregatorValues<T>
-
- Type Parameters:
T
- the output type of the aggregator
public abstract class AggregatorValues<T> extends Object
A collection of values associated with anAggregator
. Aggregators declared in aDoFn
are emitted on a per-DoFn
-application basis.
-
-
Constructor Summary
Constructors Constructor and Description AggregatorValues()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method and Description T
getTotalValue(Combine.CombineFn<T,?,T> combineFn)
Get the total value of thisAggregator
by applying the specifiedCombine.CombineFn
.Collection<T>
getValues()
Get the values of theAggregator
at all steps it was used.abstract Map<String,T>
getValuesAtSteps()
Get the values of theAggregator
by the user name at each step it was used.
-
-
-
Method Detail
-
getValues
public Collection<T> getValues()
Get the values of theAggregator
at all steps it was used.
-
getValuesAtSteps
public abstract Map<String,T> getValuesAtSteps()
Get the values of theAggregator
by the user name at each step it was used.
-
getTotalValue
public T getTotalValue(Combine.CombineFn<T,?,T> combineFn)
Get the total value of thisAggregator
by applying the specifiedCombine.CombineFn
.
-
-