ensureSchemaMatches
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.