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)


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

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

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