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)


Оцените, насколько информация на этой странице была вам полезна:

Оставить отзыв о...

Текущей странице
Cloud Dataflow
Нужна помощь? Обратитесь в службу поддержки.