Combine.AccumulatingCombineFn.Accumulator (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms

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

    • 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.


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow