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

PipelineCompletionHandler

class PipelineCompletionHandler(aggStore: AggregateStore, stateHistogramStore: StateHistogramStore, statsStore: CommittedStatsStore, dispatcher: CoroutineDispatcher)

Constructors

Link copied to clipboard
constructor(aggStore: AggregateStore, stateHistogramStore: StateHistogramStore, statsStore: CommittedStatsStore, dispatcher: CoroutineDispatcher)

Functions

Link copied to clipboard
suspend fun apply(cause: Throwable?)