class Google::Apis::DataflowV1b3::RuntimeEnvironment

The environment values to set at runtime.

Attributes

additional_experiments[RW]

Additional experiment flags for the job, specified with the `–experiments` option. Corresponds to the JSON property `additionalExperiments` @return [Array<String>]

additional_user_labels[RW]

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>]

bypass_temp_dir_validation[RW]

Whether to bypass the safety checks for the job's temporary directory. Use with caution. Corresponds to the JSON property `bypassTempDirValidation` @return [Boolean]

bypass_temp_dir_validation?[RW]

Whether to bypass the safety checks for the job's temporary directory. Use with caution. Corresponds to the JSON property `bypassTempDirValidation` @return [Boolean]

enable_streaming_engine[RW]

Whether to enable Streaming Engine for the job. Corresponds to the JSON property `enableStreamingEngine` @return [Boolean]

enable_streaming_engine?[RW]

Whether to enable Streaming Engine for the job. Corresponds to the JSON property `enableStreamingEngine` @return [Boolean]

ip_configuration[RW]

Configuration for VM IPs. Corresponds to the JSON property `ipConfiguration` @return [String]

kms_key_name[RW]

Name for the Cloud KMS key for the job. Key format is: projects//locations// keyRings//cryptoKeys/ Corresponds to the JSON property `kmsKeyName` @return [String]

machine_type[RW]

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]

max_workers[RW]

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[RW]

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]

num_workers[RW]

The initial number of Google Compute Engine instnaces for the job. Corresponds to the JSON property `numWorkers` @return [Fixnum]

service_account_email[RW]

The email address of the service account to run the job as. Corresponds to the JSON property `serviceAccountEmail` @return [String]

subnetwork[RW]

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]

temp_location[RW]

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]

worker_region[RW]

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]

worker_zone[RW]

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]

zone[RW]

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

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3956
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

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