CombineFnBase.GlobalCombineFn (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 CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>

    • Method Detail

      • getAccumulatorCoder

        Coder<AccumT> getAccumulatorCoder(CoderRegistry registry,
                                          Coder<InputT> inputCoder)
                                   throws CannotProvideCoderException
        Returns the Coder to use for accumulator AccumT values, or null if it is not able to be inferred.

        By default, uses the knowledge of the Coder being used for InputT values and the enclosing Pipeline's CoderRegistry to try to infer the Coder for AccumT values.

        This is the Coder used to send data through a communication-intensive shuffle step, so a compact and efficient representation may have significant performance benefits.

        Throws:
        CannotProvideCoderException
      • getDefaultOutputCoder

        Coder<OutputT> getDefaultOutputCoder(CoderRegistry registry,
                                             Coder<InputT> inputCoder)
                                      throws CannotProvideCoderException
        Returns the Coder to use by default for output OutputT values, or null if it is not able to be inferred.

        By default, uses the knowledge of the Coder being used for input InputT values and the enclosing Pipeline's CoderRegistry to try to infer the Coder for OutputT values.

        Throws:
        CannotProvideCoderException
      • getIncompatibleGlobalWindowErrorMessage

        String getIncompatibleGlobalWindowErrorMessage()
        Returns the error message for not supported default values in Combine.globally().
      • defaultValue

        OutputT defaultValue()
        Returns the default value when there are no values added to the accumulator.


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

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

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