PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironmentArgs

data class PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironmentArgs(val additionalExperiments: Output<List<String>>? = null, val additionalUserLabels: Output<Map<String, String>>? = null, val enableStreamingEngine: Output<Boolean>? = null, val flexrsGoal: Output<String>? = null, val ipConfiguration: Output<String>? = null, val kmsKeyName: Output<String>? = null, val machineType: Output<String>? = null, val maxWorkers: Output<Int>? = null, val network: Output<String>? = null, val numWorkers: Output<Int>? = null, val serviceAccountEmail: Output<String>? = null, val subnetwork: Output<String>? = null, val tempLocation: Output<String>? = null, val workerRegion: Output<String>? = null, val workerZone: Output<String>? = null, val zone: Output<String>? = null) : ConvertibleToJava<PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironmentArgs>

Constructors

constructor(additionalExperiments: Output<List<String>>? = null, additionalUserLabels: Output<Map<String, String>>? = null, enableStreamingEngine: Output<Boolean>? = null, flexrsGoal: Output<String>? = null, ipConfiguration: Output<String>? = null, kmsKeyName: Output<String>? = null, machineType: Output<String>? = null, maxWorkers: Output<Int>? = null, network: Output<String>? = null, numWorkers: Output<Int>? = null, serviceAccountEmail: Output<String>? = null, subnetwork: Output<String>? = null, tempLocation: Output<String>? = null, workerRegion: Output<String>? = null, workerZone: Output<String>? = null, zone: Output<String>? = null)

Properties

Link copied to clipboard
val additionalExperiments: Output<List<String>>? = null

Additional experiment flags for the job.

Link copied to clipboard
val additionalUserLabels: Output<Map<String, String>>? = null

Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the labeling restrictions page. An object containing a list of key/value pairs. 'Example: { "name": "wrench", "mass": "1kg", "count": "3" }.' 'An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1.3kg", "count": "3" }.'

Link copied to clipboard
val enableStreamingEngine: Output<Boolean>? = null

Whether to enable Streaming Engine for the job.

Link copied to clipboard
val flexrsGoal: Output<String>? = null

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs https://cloud.google.com/dataflow/docs/reference/data-pipelines/rest/v1/projects.locations.pipelines#FlexResourceSchedulingGoal Possible values are: FLEXRS_UNSPECIFIED, FLEXRS_SPEED_OPTIMIZED, FLEXRS_COST_OPTIMIZED.

Link copied to clipboard
val ipConfiguration: Output<String>? = null

Configuration for VM IPs. https://cloud.google.com/dataflow/docs/reference/data-pipelines/rest/v1/projects.locations.pipelines#WorkerIPAddressConfiguration Possible values are: WORKER_IP_UNSPECIFIED, WORKER_IP_PUBLIC, WORKER_IP_PRIVATE.

Link copied to clipboard
val kmsKeyName: Output<String>? = null

'Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/'

Link copied to clipboard
val machineType: Output<String>? = null

The machine type to use for the job. Defaults to the value from the template if not specified.

Link copied to clipboard
val maxWorkers: Output<Int>? = null

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

Link copied to clipboard
val network: Output<String>? = null

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

Link copied to clipboard
val numWorkers: Output<Int>? = null

The initial number of Compute Engine instances for the job.

Link copied to clipboard
val serviceAccountEmail: Output<String>? = null

The email address of the service account to run the job as.

Link copied to clipboard
val subnetwork: Output<String>? = null

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 "https://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.

Link copied to clipboard
val tempLocation: Output<String>? = null

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://.

Link copied to clipboard
val workerRegion: Output<String>? = null

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with workerZone. If neither workerRegion nor workerZone is specified, default to the control plane's region.

Link copied to clipboard
val workerZone: Output<String>? = null

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with workerRegion. If neither workerRegion nor workerZone is specified, a zone in the control plane's region is chosen based on available capacity. If both workerZone and zone are set, workerZone takes precedence.

Link copied to clipboard
val zone: Output<String>? = null

The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, workerZone will take precedence.

Functions

Link copied to clipboard
open override fun toJava(): PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironmentArgs