createTable

fun createTable(streamDescriptor: DestinationStream.Descriptor, catalog: Catalog, schema: Schema): Table

Builds (if necessary) an Iceberg Table. This includes creating the table's namespace if it does not already exist. If the Table already exists, it is loaded from the Catalog.

Return

The Iceberg Table, created if it does not yet exist.

Parameters

streamDescriptor

The DestinationStream.Descriptor that contains the Airbyte stream's namespace and name.

catalog

The Iceberg Catalog that contains the Table or should contain it once created.

schema

The Iceberg Schema associated with the Table.

properties

The Table configuration properties derived from the Catalog.