Skip to main content

register_delta_table

Function register_delta_table 

Source
pub async fn register_delta_table(
    ctx: &SessionContext,
    name: &str,
    table_uri: &str,
    storage_options: HashMap<String, String>,
) -> Result<(), ConnectorError>
Expand description

Opens a Delta Lake table and registers it as a table provider in the given DataFusion SessionContext.

§Arguments

  • ctx - The DataFusion session context to register in
  • name - The SQL table name (e.g., "trades")
  • table_uri - Path to the Delta Lake table (local, s3://, az://, gs://)
  • storage_options - Storage credentials and configuration

§Errors

Returns ConnectorError::ConnectionFailed if the table cannot be opened, or ConnectorError::Internal if registration fails.