Deliver data to Snowflake
Snowflake is a cloud-based data warehousing platform that allows for scalable and efficient data storage and analysis.
Quick Start
Connect in minutes with SQL
Use CREATE SINK to deliver processed data from RisingWave to Snowflake. Define your transformation logic in SQL and let RisingWave handle delivery, retries, and exactly-once semantics.
CREATE SINK snowflake_sink AS
SELECT
order_status,
COUNT(*) as order_count,
SUM(total_amount) as total_revenue,
AVG(total_amount) as avg_order_value,
MIN(last_updated) as first_order_time,
MAX(last_updated) as last_order_time
FROM orders_rw
WITH (
connector = 'snowflake',
type = 'append-only',
s3.bucket_name = 'my_s3_bucket',
s3.credentials.access = 'credentials_access',
s3.credentials.secret = 'credientials_secret',
s3.region_name = 'us-west-2',
s3.path = 'data/uploads/',
force_append_only = 'true'
);For comprehensive configuration details, please refer to the Snowflake connector documentation.
Capabilities
What you can do with RisingWave + Snowflake
Continuous Delivery
Automatically sink processed results from RisingWave to Snowflake as new data arrives. No batch jobs needed.
Exactly-once Semantics
Guaranteed data correctness when delivering to Snowflake with barrier-based checkpointing.
Upsert & Append
Support both append-only and upsert modes when sinking to Snowflake, depending on your use case.
Sink Decoupling
Built-in buffering ensures RisingWave stays stable even if Snowflake experiences temporary slowdowns.
Start streaming in minutes
Connect to Snowflake with just a few lines of SQL. No infrastructure to manage, no code to write.
