bulk-cdk-core-load/io.airbyte.cdk.load.pipeline/LoadPipeline

LoadPipeline

abstract class LoadPipeline(steps: List<LoadPipelineStep>)

Used internally by the pipeline to assemble a launcher for any loader's pipeline. CDK devs can use this to implement new flavors of interface. Connector devs should generally avoid using this.

Inheritors

Constructors

Link copied to clipboard
constructor(steps: List<LoadPipelineStep>)

Functions

Link copied to clipboard
suspend fun start(launcher: suspend (Task) -> Unit)
Link copied to clipboard
open suspend fun stop()

For closing intermediate queues or other resources.