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.


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

Send feedback about...

Cloud Dataflow