Combine.AccumulatingCombineFn.Accumulator (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.transforms

Interface Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>

• Enclosing class:

  Combine.AccumulatingCombineFn<InputT,AccumT extends Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>,OutputT>

  ---

  
  

  public static interface Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>

  The type of mutable accumulator values used by this AccumulatingCombineFn.

• • Method Summary

    All Methods Instance Methods Abstract Methods 

    Modifier and Type	Method and Description
    void	addInput(InputT input) Adds the given input value to this accumulator, modifying this accumulator.
    OutputT	extractOutput() Returns the output value that is the result of combining all the input values represented by this accumulator.
    void	mergeAccumulator(AccumT other) Adds the input values represented by the given accumulator into this accumulator.

• • Method Detail

    • addInput

      void addInput(InputT input)

      Adds the given input value to this accumulator, modifying this accumulator.

    • mergeAccumulator

      void mergeAccumulator(AccumT other)

      Adds the input values represented by the given accumulator into this accumulator.

    • extractOutput

      OutputT extractOutput()

      Returns the output value that is the result of combining all the input values represented by this accumulator.