faucet_source_bigquery/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-source-bigquery
4//!
5//! BigQuery query source connector for the faucet-stream ecosystem.
6//!
7//! Runs a SQL query against BigQuery via `jobs.query` + `jobs.getQueryResults`
8//! and streams the rows back as `serde_json::Value` records.
9
10pub mod config;
11pub mod convert;
12/// BigQuery Storage Read API (gRPC) Arrow path (#380). Only compiled with the
13/// `arrow` feature.
14#[cfg(feature = "arrow")]
15pub mod storage_read;
16pub mod stream;
17
18pub use faucet_core::{FaucetError, Source};
19
20pub use config::{BigQueryCredentials, BigQuerySourceConfig};
21pub use stream::BigQuerySource;