bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping/TypingDedupingWriter

TypingDedupingWriter

class TypingDedupingWriter(names: TableCatalog, stateGatherer: DatabaseInitialStatusGatherer<TypingDedupingDatabaseInitialStatus>, databaseHandler: DatabaseHandler, rawTableOperations: TypingDedupingRawTableOperations, finalTableOperations: TypingDedupingFinalTableOperations, disableTypeDedupe: Boolean, streamStateStore: StreamStateStore<TypingDedupingExecutionConfig>) : DestinationWriter

Constructors

Link copied to clipboard
constructor(names: TableCatalog, stateGatherer: DatabaseInitialStatusGatherer<TypingDedupingDatabaseInitialStatus>, databaseHandler: DatabaseHandler, rawTableOperations: TypingDedupingRawTableOperations, finalTableOperations: TypingDedupingFinalTableOperations, disableTypeDedupe: Boolean, streamStateStore: StreamStateStore<TypingDedupingExecutionConfig>)

Functions

Link copied to clipboard
open override fun createStreamLoader(stream: DestinationStream): StreamLoader
Link copied to clipboard
open suspend override fun setup()
Link copied to clipboard
open suspend fun teardown(destinationFailure: DestinationFailure?)