TypingDedupingFinalTableOperations
class TypingDedupingFinalTableOperations(sqlGenerator: TypingDedupingSqlGenerator, databaseHandler: DatabaseHandler)
Functions
Link copied to clipboard
fun createFinalTable(stream: DestinationStream, finalTableName: TableName, columnNameMapping: ColumnNameMapping, finalTableSuffix: String, replace: Boolean)
Link copied to clipboard
fun overwriteFinalTable(stream: DestinationStream, finalTableName: TableName, finalTableSuffix: String)
Attempt to atomically swap the final table from the temp version. This could be destination specific, INSERT INTO..SELECT * and DROP TABLE OR CREATE OR REPLACE ... SELECT *, DROP TABLE
Link copied to clipboard
fun softResetFinalTable(stream: DestinationStream, tableNames: TableNames, columnNameMapping: ColumnNameMapping)
Reset the final table using a temp table or ALTER existing table's columns.
Link copied to clipboard
fun typeAndDedupe(stream: DestinationStream, tableNames: TableNames, columnNameMapping: ColumnNameMapping, maxProcessedTimestamp: Instant?, finalTableSuffix: String)