YodaHTAP for Rust, lightweight and serverless

use yoda::{HtapConfig, HtapEngine, OlapBackendType, TableSchema};
use arrow::datatypes::{DataType, Field, Schema};
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut engine = HtapEngine::new(HtapConfig {
        oltp_path: "./yoda.db".into(),
        olap_in_memory: true,
        olap_backend: OlapBackendType::DataFusion,
        ..Default::default()
    }).await?;

    // Register a table — schema replicates to OLAP, CDC triggers wire up automatically.
    let schema = Arc::new(Schema::new(vec![
        Field::new("id", DataType::Int64, false),
        Field::new("name", DataType::Utf8, true),
    ]));
    engine.register_table(TableSchema::new("users", schema, vec!["id".into()])).await?;

    // Writes go to OLTP.
    engine.execute("INSERT INTO users VALUES (1, 'Ada'), (2, 'Grace')", &[]).await?;

    // Analytical queries route to OLAP automatically.
    let batches = engine.query("SELECT COUNT(*) FROM users").await?;
    println!("{} batch(es) returned", batches.len());

    engine.shutdown().await;
    Ok(())
}