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)


このページは役立ちましたか?評価をお願いいたします。

フィードバックを送信...

ご不明な点がありましたら、Google のサポートページをご覧ください。