faucet_sink_snowflake/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-sink-snowflake
4//!
5//! Snowflake sink connector for the faucet-stream ecosystem.
6//!
7//! Writes `serde_json::Value` records to a Snowflake table using the
8//! [Snowflake SQL REST API](https://docs.snowflake.com/en/developer-guide/sql-api/reference).
9
10/// Arrow columnar bulk-load helpers (external-stage Parquet + `COPY INTO`,
11/// #381). Only compiled with the `arrow` feature.
12#[cfg(feature = "arrow")]
13pub mod bulk;
14pub mod config;
15pub mod idempotent;
16pub mod sink;
17
18pub use faucet_core::{FaucetError, Sink};
19
20pub use config::{SnowflakeAuth, SnowflakeSinkConfig, SnowflakeStageConfig};
21pub use sink::SnowflakeSink;