Package-level declarations
Types
Link copied to clipboard
@Singleton
class DestinationLifecycle(destinationInitializer: DestinationWriter, destinationCatalog: DestinationCatalog, pipeline: PipelineRunner, completionTracker: StreamCompletionTracker, @Named(value = "streamInitDispatcher"