CREATE SINK command to create a sink. A sink is an external target where you can send data processed in RisingWave. You can create a sink from a table or source, or a materialized view.
If your goal is to create an append-only sink, you can use the emit-on-window-close policy when creating the materialized view that you want to sink data from. For details about the policy, see Emit on window close.
CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
connector_parameter = 'value', ...
[ FORMAT data_format ENCODE data_encode [ (
format_parameter = 'value'
) ] ];
FORMAT data_format ENCODE data_encode syntax is only used for Kafka, Kinesis, and Pulsar sinks.
Click a sink name to see the SQL syntax, options, and sample statement of sinking data from RisingWave to the sink.
- Apache Doris
- Apache Iceberg
- AWS Kinesis
- Cassandra or ScyllaDB
- Delta Lake
- Google BigQuery
- Kafka (Supports versions 3.1.0 or later)
- MySQL (Supports versions 5.7 and 8.0.x)
DROP SINK — Remove a sink.
SHOW CREATE SINK — Show the SQL statement used to create a sink.
Timestamptz values are stored in UTC.
When sinking downstream, timestamptz is represented in i64 with a resolution of microseconds.