class Google::Apis::DatapipelinesV1::GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
The environment values to be set at runtime for a Flex Template.
Attributes
Additional experiment flags for the job. Corresponds to the JSON property ‘additionalExperiments` @return [Array<String>]
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](cloud. google.com/compute/docs/labeling-resources#restrictions). 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 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]
Set FlexRS goal for the job. cloud.google.com/dataflow/docs/guides/ flexrs Corresponds to the JSON property ‘flexrsGoal` @return [String]
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 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 Compute Engine instances 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, defaults to the control plane 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 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/datapipelines_v1/classes.rb, line 170 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/datapipelines_v1/classes.rb, line 175 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) @enable_streaming_engine = args[:enable_streaming_engine] if args.key?(:enable_streaming_engine) @flexrs_goal = args[:flexrs_goal] if args.key?(:flexrs_goal) @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