DataflowWorkerHarnessOptions (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 DataflowWorkerHarnessOptions

    • Method Detail

      • getWorkerId

        String getWorkerId()
        The identity of the worker running this pipeline.
      • setWorkerId

        void setWorkerId(String value)
      • getJobId

        String getJobId()
        The identity of the Dataflow job.
      • setJobId

        void setJobId(String value)
      • getWorkerCacheMb

        @Default.Integer(value=100)
        Integer getWorkerCacheMb()
        The size of the worker's in-memory cache, in megabytes.

        Currently, this cache is used for storing read values of side inputs.

      • setWorkerCacheMb

        void setWorkerCacheMb(Integer value)


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

Send feedback about...

Cloud Dataflow