Skip to main content

create_and_load_table_impl

Function create_and_load_table_impl 

Source
pub async fn create_and_load_table_impl(
    config: &IcebergConfig,
    param: &SinkParam,
) -> Result<Table>
Expand description

Creates the table if configured, loads it, and checks table properties that do not depend on its current schema.

Unlike create_and_validate_table_impl, this does not require the current Iceberg schema to match param. During recovery, a durably recorded sink schema change may still need to be committed before the two schemas match again.