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
3381 3382 3383 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3381 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
3316 3317 3318 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3316 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
3325 3326 3327 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3325 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
3331 3332 3333 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3331 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
3338 3339 3340 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3338 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
3344 3345 3346 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3344 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
3350 3351 3352 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3350 def network @network end |
#num_workers ⇒ Fixnum
The initial number of Google Compute Engine instnaces for the job.
Corresponds to the JSON property numWorkers
3355 3356 3357 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3355 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
3360 3361 3362 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3360 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
3366 3367 3368 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3366 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
3372 3373 3374 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3372 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
3379 3380 3381 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3379 def zone @zone end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3386 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 |