DirectLoadTableNativeOperations

Operations which aren't easily represented as a sequence of SQL statements.

Functions

abstract suspend fun ensureSchemaMatches(stream: DestinationStream, tableName: TableName, columnNameMapping: ColumnNameMapping)

Detect the existing schema of the table, and alter it if needed to match the correct schema.

abstract suspend fun getGenerationId(tableName: TableName): Long

Return the generation ID of an arbitrary record from the table. May assume the table exists and is nonempty.