Use the 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 a materialized view.
Parameter | Description |
---|---|
sink_name | The name of the sink. |
col_name | The name of the column. |
sink_from | Specify the direct data source for output. It can be a materialized view or a table. |
select_query | Specify the data to be output to the sink. |
snapshot | Optional. Currently, to modify the definition or query of an existing sink, you need to drop and re-create the sink, but this approach generates excessive duplicates due to the mandatory backfilling. To avoid this, you can set the parameter to false to skip the backfilling phase and transmit only incremental changes. This option is only applicable when using the CREATE SINK FROM syntax, not CREATE SINK AS syntax. The default value is true. |
WITH clause | Specify the connector settings here if trying to store all the sink data. See Supported sinks for the full list of supported sink as well as links to specific connector pages detailing the syntax for each sink. |
FORMAT and ENCODE options | Optional. Specify the data format and the encoding format of the sink data. It is only used for Kafka, Kinesis, Pulsar, and Redis sinks. |
2023-11-11T18:30:09.453000Z
.