Skip to main content

Module delta_table_provider

Module delta_table_provider 

Source
Expand description

Delta Lake table provider integration with DataFusion.

This module provides a thin helper to open a Delta Lake table and register it as a TableProvider in a SessionContext.

§Usage

use laminar_connectors::lakehouse::delta_table_provider::register_delta_table;
use datafusion::prelude::SessionContext;
use std::collections::HashMap;

let ctx = SessionContext::new();
register_delta_table(&ctx, "my_table", "/path/to/delta/table", HashMap::new()).await?;

// Now query it:
let df = ctx.sql("SELECT * FROM my_table").await?;

Functions§

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