Crate faucet_sink_snowflake 

faucet-sink-snowflake

Snowflake sink connector for the faucet-stream ecosystem.

Writes serde_json::Value records to a Snowflake table using the Snowflake SQL REST API.

Re-exports

pub use config::SnowflakeSinkConfig;

pub use config::SnowflakeStageConfig;

pub use sink::SnowflakeSink;

Modules

bulkarrow

Arrow columnar bulk-load helpers (external-stage Parquet + COPY INTO, #381). Only compiled with the arrow feature. Arrow columnar bulk-load helpers (#381) — Parquet encode, external-stage upload, and the COPY INTO statement builder.

config

Snowflake sink configuration.

idempotent

Pure SQL generation for the Snowflake exactly-once (effectively-once) write path (#291).

sink

Snowflake SQL REST API sink.

Enums

FaucetError

All possible errors returned by faucet-stream.

SnowflakeAuth

Authentication method for Snowflake.

Traits

Sink

A sink writes records to an external system.