bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.pipeline/PipelineRunner

PipelineRunner

@Singleton
class PipelineRunner(reconciler: StateReconciler, store: StateStore, pipelines: List<DataFlowPipeline>, inputStreams: ConnectorInputStreams, @Named(value = "pipelineRunnerScope") pipelineScope: CoroutineScope, @Named(value = "aggregationDispatcher") aggregationDispatcher: CoroutineDispatcher)

Orchestrates the running of pipelines in parallel, handles and propagates errors and manages the state reconciler lifecycle.

Constructors

Link copied to clipboard
constructor(reconciler: StateReconciler, store: StateStore, pipelines: List<DataFlowPipeline>, inputStreams: ConnectorInputStreams, @Named(value = "pipelineRunnerScope") pipelineScope: CoroutineScope, @Named(value = "aggregationDispatcher") aggregationDispatcher: CoroutineDispatcher)

Functions

Link copied to clipboard
suspend fun run()