class Google::Apis::DataflowV1b3::FlexTemplateRuntimeEnvironment
The environment values to be set at runtime for 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) 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>]
The algorithm to use for autoscaling Corresponds to the JSON property `autoscalingAlgorithm` @return [String]
Worker disk size, in gigabytes. Corresponds to the JSON property `diskSizeGb` @return [Fixnum]
If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory. The location of the heap file will either be echoed back to the user, or the user will be given the opportunity to download the heap file. Corresponds to the JSON property `dumpHeapOnOom` @return [Boolean]
If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory. The location of the heap file will either be echoed back to the user, or the user will be given the opportunity to download the heap file. Corresponds to the JSON property `dumpHeapOnOom` @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]
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 launching the job. The default is n1-standard-1. Corresponds to the JSON property `launcherMachineType` @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 instances for the job. Corresponds to the JSON property `numWorkers` @return [Fixnum]
Cloud Storage bucket (directory) to upload heap dumps to the given location. Enabling this implies that heap dumps should be generated on OOM ( dump_heap_on_oom
is set to true). Corresponds to the JSON property `saveHeapDumpsToGcsPath` @return [String]
Docker registry location of container image to use for the 'worker harness. Default is the container for the version of the SDK. Note this field is only valid for portable pipelines. Corresponds to the JSON property `sdkContainerImage` @return [String]
The email address of the service account to run the job as. Corresponds to the JSON property `serviceAccountEmail` @return [String]
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`. Corresponds to the JSON property `stagingLocation` @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 1601 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 1606 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) @autoscaling_algorithm = args[:autoscaling_algorithm] if args.key?(:autoscaling_algorithm) @disk_size_gb = args[:disk_size_gb] if args.key?(:disk_size_gb) @dump_heap_on_oom = args[:dump_heap_on_oom] if args.key?(:dump_heap_on_oom) @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) @launcher_machine_type = args[:launcher_machine_type] if args.key?(:launcher_machine_type) @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) @save_heap_dumps_to_gcs_path = args[:save_heap_dumps_to_gcs_path] if args.key?(:save_heap_dumps_to_gcs_path) @sdk_container_image = args[:sdk_container_image] if args.key?(:sdk_container_image) @service_account_email = args[:service_account_email] if args.key?(:service_account_email) @staging_location = args[:staging_location] if args.key?(:staging_location) @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