Class: Google::Apis::DataflowV1b3::RuntimeEnvironment
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::RuntimeEnvironment
- 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
The environment values to set at runtime.
Instance Attribute Summary collapse
-
#additional_experiments ⇒ Array<String>
Additional experiment flags for the job.
-
#additional_user_labels ⇒ Hash<String,String>
Additional user labels to be specified for the job.
-
#bypass_temp_dir_validation ⇒ Boolean
(also: #bypass_temp_dir_validation?)
Whether to bypass the safety checks for the job's temporary directory.
-
#machine_type ⇒ String
The machine type to use for the job.
-
#max_workers ⇒ Fixnum
The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
-
#network ⇒ String
Network to which VMs will be assigned.
-
#num_workers ⇒ Fixnum
The initial number of Google Compute Engine instnaces for the job.
-
#service_account_email ⇒ String
The email address of the service account to run the job as.
-
#subnetwork ⇒ String
Subnetwork to which VMs will be assigned, if desired.
-
#temp_location ⇒ String
The Cloud Storage path to use for temporary files.
-
#zone ⇒ String
The Compute Engine availability zone for launching worker instances to run your pipeline.
Instance Method Summary collapse
-
#initialize(**args) ⇒ RuntimeEnvironment
constructor
A new instance of RuntimeEnvironment.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ RuntimeEnvironment
Returns a new instance of RuntimeEnvironment
3380 3381 3382 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3380 def initialize(**args) update!(**args) end |
Instance Attribute Details
#additional_experiments ⇒ Array<String>
Additional experiment flags for the job.
Corresponds to the JSON property additionalExperiments
3315 3316 3317 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3315 def additional_experiments @additional_experiments end |
#additional_user_labels ⇒ Hash<String,String>
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
Corresponds to the JSON property additionalUserLabels
3324 3325 3326 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3324 def additional_user_labels @additional_user_labels end |
#bypass_temp_dir_validation ⇒ Boolean Also known as: bypass_temp_dir_validation?
Whether to bypass the safety checks for the job's temporary directory.
Use with caution.
Corresponds to the JSON property bypassTempDirValidation
3330 3331 3332 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3330 def bypass_temp_dir_validation @bypass_temp_dir_validation end |
#machine_type ⇒ String
The machine type to use for the job. Defaults to the value from the
template if not specified.
Corresponds to the JSON property machineType
3337 3338 3339 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3337 def machine_type @machine_type end |
#max_workers ⇒ Fixnum
The maximum number of Google Compute Engine instances to be made
available to your pipeline during execution, from 1 to 1000.
Corresponds to the JSON property maxWorkers
3343 3344 3345 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3343 def max_workers @max_workers end |
#network ⇒ String
Network to which VMs will be assigned. If empty or unspecified,
the service will use the network "default".
Corresponds to the JSON property network
3349 3350 3351 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3349 def network @network end |
#num_workers ⇒ Fixnum
The initial number of Google Compute Engine instnaces for the job.
Corresponds to the JSON property numWorkers
3354 3355 3356 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3354 def num_workers @num_workers end |
#service_account_email ⇒ String
The email address of the service account to run the job as.
Corresponds to the JSON property serviceAccountEmail
3359 3360 3361 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3359 def service_account_email @service_account_email end |
#subnetwork ⇒ String
Subnetwork to which VMs will be assigned, if desired. Expected to be of
the form "regions/REGION/subnetworks/SUBNETWORK".
Corresponds to the JSON property subnetwork
3365 3366 3367 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3365 def subnetwork @subnetwork end |
#temp_location ⇒ String
The Cloud Storage path to use for temporary files.
Must be a valid Cloud Storage URL, beginning with gs://.
Corresponds to the JSON property tempLocation
3371 3372 3373 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3371 def temp_location @temp_location end |
#zone ⇒ String
The Compute Engine availability
zone
for launching worker instances to run your pipeline.
Corresponds to the JSON property zone
3378 3379 3380 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3378 def zone @zone end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3385 def update!(**args) @additional_experiments = args[:additional_experiments] if args.key?(:additional_experiments) @additional_user_labels = args[:additional_user_labels] if args.key?(:additional_user_labels) @bypass_temp_dir_validation = args[:bypass_temp_dir_validation] if args.key?(:bypass_temp_dir_validation) @machine_type = args[:machine_type] if args.key?(:machine_type) @max_workers = args[:max_workers] if args.key?(:max_workers) @network = args[:network] if args.key?(:network) @num_workers = args[:num_workers] if args.key?(:num_workers) @service_account_email = args[:service_account_email] if args.key?(:service_account_email) @subnetwork = args[:subnetwork] if args.key?(:subnetwork) @temp_location = args[:temp_location] if args.key?(:temp_location) @zone = args[:zone] if args.key?(:zone) end |