DirectLoadTableWriter

class DirectLoadTableWriter(internalNamespace: String, names: TableCatalog, stateGatherer: DatabaseInitialStatusGatherer<DirectLoadInitialStatus>, destinationHandler: DatabaseHandler, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator) : DestinationWriter

Parameters

directLoadTableTempTableNameMigration

Iff you are implementing a destination which previously existed, and used the T+D style of temporary tables (i.e. suffixing the final table with _airbyte_tmp), you MUST provide this object.

Constructors

Link copied to clipboard
constructor(internalNamespace: String, names: TableCatalog, stateGatherer: DatabaseInitialStatusGatherer<DirectLoadInitialStatus>, destinationHandler: DatabaseHandler, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator)

Functions

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