use std::sync::Arc;
use datafusion::error::Result;
use datafusion::prelude::{DataFrame, SessionContext};
use hudi_datafusion::HudiDataSource;
#[tokio::main]
async fn main() -> Result<()> {
let ctx = SessionContext::new();
let hudi = HudiDataSource::new("/tmp/trips_table");
ctx.register_table("trips_table", Arc::new(hudi))?;
let df: DataFrame = ctx.sql("SELECT * from trips_table where fare > 20.0").await?;
df.show().await?;
Ok(())
}
yihua / hudi-rs Goto Github PK
View Code? Open in Web Editor NEWThis project forked from apache/hudi-rs
A native Rust library for Apache Hudi, with bindings into Python
Home Page: https://hudi.apache.org/
License: Apache License 2.0