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

TypingDedupingStreamLoader

class TypingDedupingStreamLoader(val stream: DestinationStream, initialStatus: TypingDedupingDatabaseInitialStatus, tableNames: TableNames, columnNameMapping: ColumnNameMapping, rawTableOperations: TypingDedupingRawTableOperations, finalTableOperations: TypingDedupingFinalTableOperations, disableTypeDedupe: Boolean, streamStateStore: StreamStateStore<TypingDedupingExecutionConfig>) : StreamLoader

Constructors

Link copied to clipboard
constructor(stream: DestinationStream, initialStatus: TypingDedupingDatabaseInitialStatus, tableNames: TableNames, columnNameMapping: ColumnNameMapping, rawTableOperations: TypingDedupingRawTableOperations, finalTableOperations: TypingDedupingFinalTableOperations, disableTypeDedupe: Boolean, streamStateStore: StreamStateStore<TypingDedupingExecutionConfig>)

Properties

Link copied to clipboard
open override val stream: DestinationStream

Functions

Link copied to clipboard
open suspend override fun close(hadNonzeroRecords: Boolean, streamFailure: StreamProcessingFailed?)
Link copied to clipboard
open suspend override fun start()
Link copied to clipboard
open suspend fun teardown(completedSuccessfully: Boolean)