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
5867 5868 5869 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5867 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
5832 5833 5834 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5832 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
5837 5838 5839 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5837 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
5844 5845 5846 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5844 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
5850 5851 5852 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5850 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
5860 5861 5862 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5860 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
5865 5866 5867 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5865 def worker_id @worker_id end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
5872 5873 5874 5875 5876 5877 5878 5879 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5872 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 |