bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.pipeline.db/InsertLoaderPipeline

InsertLoaderPipeline

@Singleton
@Requires(bean = InsertLoader::class)
class InsertLoaderPipeline<Q : InsertLoaderRequest>(requestBuilderStep: InsertLoaderRequestBuilderStep<Q>, requestExecutorStep: InsertLoaderRequestExecutorStep<Q>) : LoadPipeline

Constructors

Link copied to clipboard
constructor(requestBuilderStep: InsertLoaderRequestBuilderStep<Q>, requestExecutorStep: InsertLoaderRequestExecutorStep<Q>)

Functions

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