AggregatorValues (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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 an Aggregator. Aggregators declared in a DoFn 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 this Aggregator by applying the specified Combine.CombineFn.
    Collection<T>	getValues() Get the values of the Aggregator at all steps it was used.
    abstract Map<String,T>	getValuesAtSteps() Get the values of the Aggregator by the user name at each step it was used.

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • Constructor Detail

    • AggregatorValues

      public AggregatorValues()

  • Method Detail

    • getValues

      public Collection<T> getValues()

      Get the values of the Aggregator at all steps it was used.

    • getValuesAtSteps

      public abstract Map<String,T> getValuesAtSteps()

      Get the values of the Aggregator by the user name at each step it was used.

    • getTotalValue

      public T getTotalValue(Combine.CombineFn<T,?,T> combineFn)

      Get the total value of this Aggregator by applying the specified Combine.CombineFn.