Class: Google::Apis::DataflowV1b3::WorkerSettings
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::WorkerSettings
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb
Overview
Provides data to pass through to the worker harness.
Instance Attribute Summary collapse
-
#base_url ⇒ String
The base URL for accessing Google Cloud APIs.
-
#reporting_enabled ⇒ Boolean
(also: #reporting_enabled?)
Whether to send work progress updates to the service.
-
#service_path ⇒ String
The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
-
#shuffle_service_path ⇒ String
The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
-
#temp_storage_prefix ⇒ String
The prefix of the resources the system should use for temporary storage.
-
#worker_id ⇒ String
The ID of the worker running this pipeline.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkerSettings
constructor
A new instance of WorkerSettings.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ WorkerSettings
Returns a new instance of WorkerSettings.
6048 6049 6050 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6048 def initialize(**args) update!(**args) end |
Instance Attribute Details
#base_url ⇒ 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/"
Corresponds to the JSON property baseUrl
6013 6014 6015 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6013 def base_url @base_url end |
#reporting_enabled ⇒ Boolean Also known as: reporting_enabled?
Whether to send work progress updates to the service.
Corresponds to the JSON property reportingEnabled
6018 6019 6020 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6018 def reporting_enabled @reporting_enabled end |
#service_path ⇒ String
The Cloud Dataflow service path relative to the root URL, for example,
"dataflow/v1b3/projects".
Corresponds to the JSON property servicePath
6025 6026 6027 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6025 def service_path @service_path end |
#shuffle_service_path ⇒ String
The Shuffle service path relative to the root URL, for example,
"shuffle/v1beta1".
Corresponds to the JSON property shuffleServicePath
6031 6032 6033 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6031 def shuffle_service_path @shuffle_service_path end |
#temp_storage_prefix ⇒ 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
Corresponds to the JSON property tempStoragePrefix
6041 6042 6043 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6041 def temp_storage_prefix @temp_storage_prefix end |
#worker_id ⇒ String
The ID of the worker running this pipeline.
Corresponds to the JSON property workerId
6046 6047 6048 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6046 def worker_id @worker_id end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
6053 6054 6055 6056 6057 6058 6059 6060 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 6053 def update!(**args) @base_url = args[:base_url] if args.key?(:base_url) @reporting_enabled = args[:reporting_enabled] if args.key?(:reporting_enabled) @service_path = args[:service_path] if args.key?(:service_path) @shuffle_service_path = args[:shuffle_service_path] if args.key?(:shuffle_service_path) @temp_storage_prefix = args[:temp_storage_prefix] if args.key?(:temp_storage_prefix) @worker_id = args[:worker_id] if args.key?(:worker_id) end |