DirectLoadSqlGenerator

Functions

abstract fun copyTable(columnNameMapping: ColumnNameMapping, sourceTableName: TableName, targetTableName: TableName): Sql

Copy all records from sourceTable to targetTable. May assume that both tables exist, and have schemas which match the expected schema, i.e. io.airbyte.cdk.load.component.TableSchemaEvolutionClient.ensureSchemaMatches was invoked on both tables.

abstract fun createTable(stream: DestinationStream, tableName: TableName, columnNameMapping: ColumnNameMapping, replace: Boolean): Sql

abstract fun dropTable(tableName: TableName): Sql

abstract fun overwriteTable(sourceTableName: TableName, targetTableName: TableName): Sql

Replace the targetTable with the sourceTable. This is typically something like

abstract fun upsertTable(stream: DestinationStream, columnNameMapping: ColumnNameMapping, sourceTableName: TableName, targetTableName: TableName): Sql