bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.orchestration.db.direct_load_table/DefaultDirectLoadTableSqlOperations

DefaultDirectLoadTableSqlOperations

open class DefaultDirectLoadTableSqlOperations(generator: DirectLoadSqlGenerator, handler: DatabaseHandler) : DirectLoadTableSqlOperations

Constructors

Link copied to clipboard
constructor(generator: DirectLoadSqlGenerator, handler: DatabaseHandler)

Functions

Link copied to clipboard
open suspend override fun copyTable(columnNameMapping: ColumnNameMapping, sourceTableName: TableName, targetTableName: TableName)
Link copied to clipboard
open suspend override fun createTable(stream: DestinationStream, tableName: TableName, columnNameMapping: ColumnNameMapping, replace: Boolean)
Link copied to clipboard
open suspend override fun dropTable(tableName: TableName)
Link copied to clipboard
open suspend override fun overwriteTable(sourceTableName: TableName, targetTableName: TableName)
Link copied to clipboard
open suspend override fun upsertTable(stream: DestinationStream, columnNameMapping: ColumnNameMapping, sourceTableName: TableName, targetTableName: TableName)