Commands
CREATE SINK INTO
Use the CREATE SINK INTO
command to create a sink into RisingWave’s table.
syntax
Parameters
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. |
A table without a primary key can only accept the append-only sink.
Currently, if there are sinks in the table, the table cannot be altered to add or drop columns.
Examples
You can union data from two different Kafka topics.
If you don’t want one of the topics, you can drop it.
See also
Was this page helpful?