bulk-cdk-core-load/io.airbyte.cdk.load.component

Package-level declarations

Types

data class ColumnChangeset(val columnsToAdd: Map<String, ColumnType>, val columnsToDrop: Map<String, ColumnType>, val columnsToChange: Map<String, ColumnTypeChange>, val columnsToRetain: Map<String, ColumnType>)

As with TableColumns, all maps are keyed by the column name as it appears in the destination.

ColumnType

data class ColumnType(val type: String, val nullable: Boolean)

ColumnTypeChange

data class ColumnTypeChange(val originalType: ColumnType, val newType: ColumnType)

TableColumns

typealias TableColumns = Map<String, ColumnType>

A map from column name to type. Note that the column name should be as it appears in the destination: for example, Snowflake upcases all identifiers, so these column names should be upcased.

TableOperationsClient

interface TableOperationsClient

Client interface for database table operations.

TableSchema

data class TableSchema(val columns: TableColumns)

Eventually we might need some sort of struct to track anything not represented in the TableColumns object. For example, Bigquery's partitioning/clustering key, Iceberg's identifier fields.

TableSchemaEvolutionClient

interface TableSchemaEvolutionClient

Database-specific schema evolution operations.