DataFusion Delta Sharing

本库提供Delta Sharing与DataFusion的集成。

Delta Sharing是一个用于安全共享大数据集的开源协议。它是一个REST协议，安全地提供了对存储在S3、ADLS和GCS等流行云存储系统上的云数据集某部分的访问。

安装

可以使用cargo安装此crate

cargo add datafusion-delta-sharing

示例

以下展示了集成示例

use std::sync::Arc;
use datafusion::prelude::*;

use datafusion_delta_sharing::DeltaSharingTable;

let ctx = SessionContext::new();
let table = DeltaSharingTable::try_from_str("./path/to/profile.share#share.schema.table").await?;

ctx.register_table("demo", Arc::new(table))?;
ctx.sql("select * from demo").await?.show().await?;