Skip to main content

faucet_transform_sql/
lib.rs

1#![cfg_attr(docsrs, feature(doc_cfg))]
2//! SQL-as-transform for faucet-stream, backed by embedded DuckDB.
3//!
4//! Each pipeline page is exposed to a SQL query as the relation `batch`; the
5//! result set becomes the new page. [`SqlTransformConfig`] is the user-facing
6//! config (the `query` plus optional reference [`RelationSpec`]s, whose data
7//! comes from a [`RelationSource`]). [`SqlTransform`] is the compiled runtime
8//! that owns the DuckDB connection and runs the query per page.
9
10mod compile;
11mod config;
12mod runtime;
13mod shovel;
14
15pub use config::{RelationSource, RelationSpec, SqlTransformConfig};
16pub use runtime::SqlTransform;