Use the CREATE SINK INTO
command to create a sink into RisingWave’s table.
Parameter or clause | Description |
---|---|
sink_name | The name of the sink. If a schema name is given (for example, CREATE SINK <schema>.<sink> ... ), then the sink is created in the specified schema. Otherwise it is created in the current schema. |
col_name | The corresponding table columns in the sink result. For those columns not listed, it will be inserted as the default value defined in the table. |
WITH clause | You can use options such as type = 'append-only' and force_append_only = 'true' to explicitly control the append-only behavior. |
CREATE SINK INTO
. To enable it, set sink_decouple = true
before creating the sink.