Skip to main content

ensure_table_exists

laminar_connectors::lakehouse::iceberg_io

Function ensure_table_exists 

Source 
pub async fn ensure_table_exists(
    catalog: &dyn Catalog,
    namespace: &str,
    table_name: &str,
    arrow_schema: &SchemaRef,
) -> Result<(), ConnectorError>
Expand description

Creates an Iceberg table (and namespace) if it does not already exist.

ยงErrors

Returns ConnectorError on creation failure.