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.


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.