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

Package-level declarations

Types

Link copied to clipboard
@Singleton
class StreamCompletionTracker(catalog: DestinationCatalog)

Tracks whether we've received stream complete messages for all streams in the catalog.