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 attached to 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
3290 3291 3292 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3290 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
3229 3230 3231 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3229 def additional_experiments @additional_experiments end |
#additional_user_labels ⇒ Hash<String,String>
Additional user labels attached to the job.
Corresponds to the JSON property additionalUserLabels
3234 3235 3236 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3234 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
3240 3241 3242 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3240 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
3247 3248 3249 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3247 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
3253 3254 3255 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3253 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
3259 3260 3261 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3259 def network @network end |
#num_workers ⇒ Fixnum
The initial number of Google Compute Engine instnaces for the job.
Corresponds to the JSON property numWorkers
3264 3265 3266 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3264 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
3269 3270 3271 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3269 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
3275 3276 3277 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3275 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
3281 3282 3283 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3281 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
3288 3289 3290 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3288 def zone @zone end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305 3306 3307 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3295 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 |