pulumi-gcp-kotlin/com.pulumi.gcp.dataflow.kotlin

Package-level declarations

Types

class FlexTemplateJob : KotlinCustomResource

data class FlexTemplateJobArgs(val additionalExperiments: Output<List<String>>? = null, val autoscalingAlgorithm: Output<String>? = null, val containerSpecGcsPath: Output<String>? = null, val enableStreamingEngine: Output<Boolean>? = null, val ipConfiguration: Output<String>? = null, val kmsKeyName: Output<String>? = null, val labels: Output<Map<String, String>>? = null, val launcherMachineType: Output<String>? = null, val machineType: Output<String>? = null, val maxWorkers: Output<Int>? = null, val name: Output<String>? = null, val network: Output<String>? = null, val numWorkers: Output<Int>? = null, val onDelete: Output<String>? = null, val parameters: Output<Map<String, String>>? = null, val project: Output<String>? = null, val region: Output<String>? = null, val sdkContainerImage: Output<String>? = null, val serviceAccountEmail: Output<String>? = null, val skipWaitOnJobTermination: Output<Boolean>? = null, val stagingLocation: Output<String>? = null, val subnetwork: Output<String>? = null, val tempLocation: Output<String>? = null, val transformNameMapping: Output<Map<String, String>>? = null) : ConvertibleToJava<FlexTemplateJobArgs>

FlexTemplateJobArgsBuilder

class FlexTemplateJobArgsBuilder

Builder for FlexTemplateJobArgs.

FlexTemplateJobMapper

object FlexTemplateJobMapper : ResourceMapper<FlexTemplateJob>

FlexTemplateJobResourceBuilder

class FlexTemplateJobResourceBuilder

Builder for FlexTemplateJob.

Job

class Job : KotlinCustomResource

Creates a job on Dataflow, which is an implementation of Apache Beam running on Google Compute Engine. For more information see the official documentation for Beam and Dataflow.

JobArgs

data class JobArgs(val additionalExperiments: Output<List<String>>? = null, val enableStreamingEngine: Output<Boolean>? = null, val ipConfiguration: Output<String>? = null, val kmsKeyName: Output<String>? = null, val labels: Output<Map<String, String>>? = null, val machineType: Output<String>? = null, val maxWorkers: Output<Int>? = null, val name: Output<String>? = null, val network: Output<String>? = null, val onDelete: Output<String>? = null, val parameters: Output<Map<String, String>>? = null, val project: Output<String>? = null, val region: Output<String>? = null, val serviceAccountEmail: Output<String>? = null, val skipWaitOnJobTermination: Output<Boolean>? = null, val subnetwork: Output<String>? = null, val tempGcsLocation: Output<String>? = null, val templateGcsPath: Output<String>? = null, val transformNameMapping: Output<Map<String, String>>? = null, val zone: Output<String>? = null) : ConvertibleToJava<JobArgs>

Creates a job on Dataflow, which is an implementation of Apache Beam running on Google Compute Engine. For more information see the official documentation for Beam and Dataflow.

JobArgsBuilder

class JobArgsBuilder

Builder for JobArgs.

JobMapper

object JobMapper : ResourceMapper<Job>

JobResourceBuilder

class JobResourceBuilder

Builder for Job.

Pipeline

class Pipeline : KotlinCustomResource

/* /* /* /* /* /* The main pipeline entity and all the necessary metadata for launching and managing linked jobs. To get more information about Pipeline, see:

PipelineArgs

data class PipelineArgs(val displayName: Output<String>? = null, val name: Output<String>? = null, val pipelineSources: Output<Map<String, String>>? = null, val project: Output<String>? = null, val region: Output<String>? = null, val scheduleInfo: Output<PipelineScheduleInfoArgs>? = null, val schedulerServiceAccountEmail: Output<String>? = null, val state: Output<String>? = null, val type: Output<String>? = null, val workload: Output<PipelineWorkloadArgs>? = null) : ConvertibleToJava<PipelineArgs>

/* /* /* /* /* /* The main pipeline entity and all the necessary metadata for launching and managing linked jobs. To get more information about Pipeline, see:

PipelineArgsBuilder

class PipelineArgsBuilder

Builder for PipelineArgs.

PipelineMapper

object PipelineMapper : ResourceMapper<Pipeline>

PipelineResourceBuilder

class PipelineResourceBuilder

Builder for Pipeline.

Functions

flexTemplateJob

fun flexTemplateJob(name: String): FlexTemplateJob

suspend fun flexTemplateJob(name: String, block: suspend FlexTemplateJobResourceBuilder.() -> Unit): FlexTemplateJob

job

fun job(name: String): Job

suspend fun job(name: String, block: suspend JobResourceBuilder.() -> Unit): Job

pipeline

fun pipeline(name: String): Pipeline

suspend fun pipeline(name: String, block: suspend PipelineResourceBuilder.() -> Unit): Pipeline