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.
-
#kms_key_name ⇒ String
Optional.
-
#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
3402 3403 3404 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3402 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
3330 3331 3332 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3330 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
3339 3340 3341 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3339 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
3345 3346 3347 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3345 def bypass_temp_dir_validation @bypass_temp_dir_validation end |
#kms_key_name ⇒ String
Optional. Name for the Cloud KMS key for the job.
Key format is:
projects/kmsKeyName
3353 3354 3355 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3353 def kms_key_name @kms_key_name 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
3359 3360 3361 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3359 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
3365 3366 3367 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3365 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
3371 3372 3373 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3371 def network @network end |
#num_workers ⇒ Fixnum
The initial number of Google Compute Engine instnaces for the job.
Corresponds to the JSON property numWorkers
3376 3377 3378 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3376 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
3381 3382 3383 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3381 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
3387 3388 3389 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3387 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
3393 3394 3395 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3393 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
3400 3401 3402 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3400 def zone @zone end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3407 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) @kms_key_name = args[:kms_key_name] if args.key?(:kms_key_name) @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 |