pulumi-google-native-kotlin/com.pulumi.googlenative.datapipelines.v1.kotlin.outputs/GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse

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

The environment values to be set at runtime for a Flex Template.

Constructors

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

Types

Companion

object Companion

Properties

additionalExperiments

val additionalExperiments: List<String>

Additional experiment flags for the job.

additionalUserLabels

val additionalUserLabels: Map<String, String>

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

enableStreamingEngine

val enableStreamingEngine: Boolean

Whether to enable Streaming Engine for the job.

flexrsGoal

val flexrsGoal: String

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

ipConfiguration

val ipConfiguration: String

Configuration for VM IPs.

kmsKeyName

val kmsKeyName: String

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

machineType

val machineType: String

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

maxWorkers

val maxWorkers: Int

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

network

val network: String

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

numWorkers

val numWorkers: Int

The initial number of Compute Engine instances for the job.

serviceAccountEmail

val serviceAccountEmail: String

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

subnetwork

val subnetwork: 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 "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.

tempLocation

val tempLocation: String

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

workerRegion

val workerRegion: String

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 worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.

workerZone

val workerZone: String

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

zone

val zone: String

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