bulk-cdk-toolkit-load-iceberg-parquet/io.airbyte.cdk.load.toolkits.iceberg.parquet

Package-level declarations

Types

Describes how the IcebergTableSynchronizer handles column type changes.

@Singleton

A utility class that determines a "supertype" given two Iceberg Types.

@Singleton

Applies schema changes to an Iceberg Table, including nested columns (struct fields).

@Singleton

Compares two Iceberg Schema definitions (including nested structs) to identify:

data class SchemaUpdateResult(val schema: Schema, val pendingUpdates: List<UpdateSchema>)

Convert our internal stream descriptor to an Iceberg TableIdentifier. Implementations should handle catalog-specific naming restrictions.

fun tableIdOf(namespace: String, name: String): TableIdentifier