class Google::Apis::DataflowV1b3::RuntimeEnvironment
The environment values to set at runtime.
Attributes
Additional experiment flags for the job, specified with the `–experiments` option. Corresponds to the JSON property `additionalExperiments` @return [Array<String>]
Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](cloud. google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of “key”: value pairs. Example: ` “name”: “wrench”, “mass”: “ 1kg”, “count”: “3” `. Corresponds to the JSON property `additionalUserLabels` @return [Hash<String,String>]
Whether to bypass the safety checks for the job's temporary directory. Use with caution. Corresponds to the JSON property `bypassTempDirValidation` @return [Boolean]
Whether to bypass the safety checks for the job's temporary directory. Use with caution. Corresponds to the JSON property `bypassTempDirValidation` @return [Boolean]
Whether to enable Streaming Engine for the job. Corresponds to the JSON property `enableStreamingEngine` @return [Boolean]
Whether to enable Streaming Engine for the job. Corresponds to the JSON property `enableStreamingEngine` @return [Boolean]
Configuration for VM IPs. Corresponds to the JSON property `ipConfiguration` @return [String]
Name for the Cloud KMS key for the job. Key format is: projects//locations// keyRings//cryptoKeys/ Corresponds to the JSON property `kmsKeyName` @return [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` @return [String]
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` @return [Fixnum]
Network to which VMs will be assigned. If empty or unspecified, the service will use the network “default”. Corresponds to the JSON property `network` @return [String]
The initial number of Google
Compute Engine instnaces for the job. Corresponds to the JSON property `numWorkers` @return [Fixnum]
The email address of the service account to run the job as. Corresponds to the JSON property `serviceAccountEmail` @return [String]
Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form “www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/ regions/REGION/subnetworks/SUBNETWORK” or “regions/REGION/subnetworks/ SUBNETWORK”. If the subnetwork is located in a Shared VPC network, you must use the complete URL. Corresponds to the JSON property `subnetwork` @return [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` @return [String]
The Compute Engine region (cloud.google.com/compute/docs/regions-zones/ regions-zones) in which worker processing should occur, e.g. “us-west1”. Mutually exclusive with worker_zone. If neither worker_region
nor worker_zone
is specified, default to the control plane's region. Corresponds to the JSON property `workerRegion` @return [String]
The Compute Engine zone (cloud.google.com/compute/docs/regions-zones/ regions-zones) in which worker processing should occur, e.g. “us-west1-a”. Mutually exclusive with worker_region. If neither worker_region
nor worker_zone
is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence. Corresponds to the JSON property `workerZone` @return [String]
The Compute Engine [availability zone](cloud.google.com/compute/docs/ regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone
will take precedence. Corresponds to the JSON property `zone` @return [String]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3956 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3961 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) @enable_streaming_engine = args[:enable_streaming_engine] if args.key?(:enable_streaming_engine) @ip_configuration = args[:ip_configuration] if args.key?(:ip_configuration) @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) @worker_region = args[:worker_region] if args.key?(:worker_region) @worker_zone = args[:worker_zone] if args.key?(:worker_zone) @zone = args[:zone] if args.key?(:zone) end