bulk-cdk-core-load/io.airbyte.cdk.load.dataflow/DestinationLifecycle

DestinationLifecycle

@Singleton
class DestinationLifecycle(destinationInitializer: DestinationWriter, destinationCatalog: DestinationCatalog, pipeline: PipelineRunner, completionTracker: StreamCompletionTracker, @Named(value = "streamInitDispatcher") streamInitDispatcher: CoroutineDispatcher, @Named(value = "streamFinalizeDispatcher") streamFinalizeDispatcher: CoroutineDispatcher)

Constructors

Link copied to clipboard
constructor(destinationInitializer: DestinationWriter, destinationCatalog: DestinationCatalog, pipeline: PipelineRunner, completionTracker: StreamCompletionTracker, @Named(value = "streamInitDispatcher") streamInitDispatcher: CoroutineDispatcher, @Named(value = "streamFinalizeDispatcher") streamFinalizeDispatcher: CoroutineDispatcher)

Functions

Link copied to clipboard
fun run()