Package-level declarations

Types

Link copied to clipboard
Link copied to clipboard
class Pipeline : KotlinCustomResource

Creates a pipeline. For a batch pipeline, you can pass scheduler information. Data Pipelines uses the scheduler information to create an internal scheduler that runs jobs periodically. If the internal scheduler is not configured, you can use RunPipeline to run jobs.

Link copied to clipboard
data class PipelineArgs(val displayName: Output<String>? = null, val location: Output<String>? = null, val name: Output<String>? = null, val pipelineSources: Output<Map<String, String>>? = null, val project: Output<String>? = null, val scheduleInfo: Output<GoogleCloudDatapipelinesV1ScheduleSpecArgs>? = null, val schedulerServiceAccountEmail: Output<String>? = null, val state: Output<PipelineState>? = null, val type: Output<PipelineType>? = null, val workload: Output<GoogleCloudDatapipelinesV1WorkloadArgs>? = null) : ConvertibleToJava<PipelineArgs>

Creates a pipeline. For a batch pipeline, you can pass scheduler information. Data Pipelines uses the scheduler information to create an internal scheduler that runs jobs periodically. If the internal scheduler is not configured, you can use RunPipeline to run jobs.

Link copied to clipboard
Link copied to clipboard
object PipelineMapper : ResourceMapper<Pipeline>
Link copied to clipboard

Functions

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