Package-level declarations

Types

Link copied to clipboard
data class GetPipelineResult(val createTime: String, val displayName: String, val jobCount: Int, val lastUpdateTime: String, val name: String, val pipelineSources: Map<String, String>, val scheduleInfo: GoogleCloudDatapipelinesV1ScheduleSpecResponse, val schedulerServiceAccountEmail: String, val state: String, val type: String, val workload: GoogleCloudDatapipelinesV1WorkloadResponse)
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.

data class GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponse(val containerSpecGcsPath: String, val environment: GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse, val jobName: String, val launchOptions: Map<String, String>, val parameters: Map<String, String>, val transformNameMappings: Map<String, String>, val update: Boolean)

Launch Flex Template parameter.

A request to launch a Dataflow job from a Flex Template.

data class GoogleCloudDatapipelinesV1LaunchTemplateParametersResponse(val environment: GoogleCloudDatapipelinesV1RuntimeEnvironmentResponse, val jobName: String, val parameters: Map<String, String>, val transformNameMapping: Map<String, String>, val update: Boolean)

Parameters to provide to the template being launched.

data class GoogleCloudDatapipelinesV1LaunchTemplateRequestResponse(val gcsPath: String, val launchParameters: GoogleCloudDatapipelinesV1LaunchTemplateParametersResponse, val location: String, val project: String, val validateOnly: Boolean)

A request to launch a template.

data class GoogleCloudDatapipelinesV1RuntimeEnvironmentResponse(val additionalExperiments: List<String>, val additionalUserLabels: Map<String, String>, val bypassTempDirValidation: Boolean, val enableStreamingEngine: Boolean, 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 set at runtime.

data class GoogleCloudDatapipelinesV1ScheduleSpecResponse(val nextJobTime: String, val schedule: String, val timeZone: String)

Details of the schedule the pipeline runs on.

Workload details for creating the pipeline jobs.