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

DirectLoadTableSqlOperations

interface DirectLoadTableSqlOperations

Operations which can be handled by an underlying DatabaseHandler executing SQL statements from a DirectLoadSqlGenerator.

Destinations MAY choose to implement their own version of this class, if they want finer control, but in general, the DefaultDirectLoadTableSqlOperations is a reasonable implementation.

Inheritors

Functions

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