Crate faucet_transform_sql 

SQL-as-transform for faucet-stream, backed by embedded DuckDB.

Each pipeline page is exposed to a SQL query as the relation batch; the result set becomes the new page. SqlTransformConfig is the user-facing config (the query plus optional reference RelationSpecs, whose data comes from a RelationSource). SqlTransform is the compiled runtime that owns the DuckDB connection and runs the query per page.

Structs

RelationSpec

A reference relation registered before the first page.

SqlTransform

A compiled SQL transform. One DuckDB connection, reused across the row’s pages.

SqlTransformConfig

Configuration for the sql transform.

Enums

RelationSource

The data source for a reference relation.