DirectPipelineOptions (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.options

Interface DirectPipelineOptions

    • Method Detail

      • getDirectPipelineRunnerRandomSeed

        Long getDirectPipelineRunnerRandomSeed()
        The random seed to use for pseudorandom behaviors in the DirectPipelineRunner. If not explicitly specified, a random seed will be generated.
      • setDirectPipelineRunnerRandomSeed

        void setDirectPipelineRunnerRandomSeed(Long value)
      • isTestSerializability

        @Default.Boolean(value=true)
        boolean isTestSerializability()
        Controls whether the runner should ensure that all of the elements of the pipeline, such as DoFns, can be serialized.
      • setTestSerializability

        void setTestSerializability(boolean testSerializability)
      • isTestEncodability

        @Default.Boolean(value=true)
        boolean isTestEncodability()
        Controls whether the runner should ensure that all of the elements of every PCollection can be encoded using the appropriate Coder.
      • setTestEncodability

        void setTestEncodability(boolean testEncodability)
      • setTestUnorderedness

        void setTestUnorderedness(boolean testUnorderedness)


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow