Skip to main content

open_or_create_partitioned_table

Function open_or_create_partitioned_table 

Source
pub async fn open_or_create_partitioned_table(
    table_path: &str,
    storage_options: HashMap<String, String>,
    schema: Option<&SchemaRef>,
    partition_columns: &[String],
) -> Result<DeltaTable, ConnectorError>
Expand description

Opens an existing Delta table, or creates it with schema partitioned by partition_columns when it is absent and a schema is supplied. An existing table keeps its own partitioning; callers compare it with their configuration.

ยงErrors

Returns ConnectorError::ConnectionFailed if the table cannot be opened or created, or ConnectorError::SchemaMismatch when a partition column is absent from schema.