PipelineWorkloadDataflowFlexTemplateRequestLaunchParameter

data class PipelineWorkloadDataflowFlexTemplateRequestLaunchParameter(val containerSpecGcsPath: String? = null, val environment: PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironment? = null, val jobName: String, val launchOptions: Map<String, String>? = null, val parameters: Map<String, String>? = null, val transformNameMappings: Map<String, String>? = null, val update: Boolean? = null)

Constructors

constructor(containerSpecGcsPath: String? = null, environment: PipelineWorkloadDataflowFlexTemplateRequestLaunchParameterEnvironment? = null, jobName: String, launchOptions: Map<String, String>? = null, parameters: Map<String, String>? = null, transformNameMappings: Map<String, String>? = null, update: Boolean? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.

Link copied to clipboard

The runtime environment for the Flex Template job. https://cloud.google.com/dataflow/docs/reference/data-pipelines/rest/v1/projects.locations.pipelines#FlexTemplateRuntimeEnvironment Structure is documented below.

Link copied to clipboard

The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.

Link copied to clipboard

Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters. 'An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1.3kg", "count": "3" }.'

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

'The parameters for the Flex Template. Example: {"numWorkers":"5"}' 'An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1.3kg", "count": "3" }.'

Link copied to clipboard

'Use this to pass transform name mappings for streaming update jobs. Example: {"oldTransformName":"newTransformName",...}' 'An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1.3kg", "count": "3" }.'

Link copied to clipboard
val update: Boolean? = null

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.