Class Google::Cloud::Dataflow::V1beta3::WorkerSettings (v0.1.4)

Provides data to pass through to the worker harness.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#base_url

def base_url() -> ::String
Returns
  • (::String) — The base URL for accessing Google Cloud APIs.

    When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, "Relative Uniform Resource Locators".

    If not specified, the default value is "http://www.googleapis.com/"

#base_url=

def base_url=(value) -> ::String
Parameter
  • value (::String) — The base URL for accessing Google Cloud APIs.

    When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, "Relative Uniform Resource Locators".

    If not specified, the default value is "http://www.googleapis.com/"

Returns
  • (::String) — The base URL for accessing Google Cloud APIs.

    When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, "Relative Uniform Resource Locators".

    If not specified, the default value is "http://www.googleapis.com/"

#reporting_enabled

def reporting_enabled() -> ::Boolean
Returns
  • (::Boolean) — Whether to send work progress updates to the service.

#reporting_enabled=

def reporting_enabled=(value) -> ::Boolean
Parameter
  • value (::Boolean) — Whether to send work progress updates to the service.
Returns
  • (::Boolean) — Whether to send work progress updates to the service.

#service_path

def service_path() -> ::String
Returns
  • (::String) — The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".

#service_path=

def service_path=(value) -> ::String
Parameter
  • value (::String) — The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
Returns
  • (::String) — The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".

#shuffle_service_path

def shuffle_service_path() -> ::String
Returns
  • (::String) — The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

#shuffle_service_path=

def shuffle_service_path=(value) -> ::String
Parameter
  • value (::String) — The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
Returns
  • (::String) — The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

#temp_storage_prefix

def temp_storage_prefix() -> ::String
Returns
  • (::String) — The prefix of the resources the system should use for temporary storage.

    The supported resource type is:

    Google Cloud Storage:

    storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}

#temp_storage_prefix=

def temp_storage_prefix=(value) -> ::String
Parameter
  • value (::String) — The prefix of the resources the system should use for temporary storage.

    The supported resource type is:

    Google Cloud Storage:

    storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}

Returns
  • (::String) — The prefix of the resources the system should use for temporary storage.

    The supported resource type is:

    Google Cloud Storage:

    storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}

#worker_id

def worker_id() -> ::String
Returns
  • (::String) — The ID of the worker running this pipeline.

#worker_id=

def worker_id=(value) -> ::String
Parameter
  • value (::String) — The ID of the worker running this pipeline.
Returns
  • (::String) — The ID of the worker running this pipeline.