faucet-source-duckdb 1.3.0

DuckDB query source connector for the faucet-stream ecosystem
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-source-duckdb
//!
//! DuckDB query source connector for the faucet-stream ecosystem.
//!
//! Opens a DuckDB database (a file, or in-memory), executes a configurable SQL
//! query, and streams rows as `serde_json::Value` records with bounded memory (DuckDB's
//! streaming Arrow interface, one chunk at a time).
//! DuckDB is the de-facto embedded analytics engine; this connector mirrors the
//! [`faucet-source-sqlite`](https://docs.rs/faucet-source-sqlite) query source.

pub mod config;
mod convert;
pub mod stream;

pub use faucet_core::{FaucetError, Source};

pub use config::DuckdbSourceConfig;
pub use stream::DuckdbSource;

/// The connector's static descriptor (RFC 0013): its capabilities, answered from config alone.
pub const DESCRIPTOR: faucet_core::ConnectorDescriptor =
    faucet_core::ConnectorDescriptor::new("duckdb", faucet_core::capabilities::plain_source);