CREATE SINK INTO

使用 CREATE SINK INTO 命令创建一个 sink 到 RisingWave 的表中。

句法

CREATE SINK [ IF NOT EXISTS ] sink_name INTO table_name
[FROM sink_from | AS select_query]

note

没有主键的表只能接受 Append-Only Sink。

note

如果当前表中有 sink，则不能更改表以添加或删除列。

示例

您可以联合两个不同 Kafka topics 的数据。

CREATE TABLE orders (
    id int primary key,
    price int,
    item_id int,
    customer_id int
);

CREATE source orders_s0 (
    id int primary key,
    price int,
    item_id int,
    customer_id int
) WITH ( 
    connector = 'kafka',
    topic = 'topic_0',
    ...
) FORMAT PLAIN ENCODE JSON;

CREATE source orders_s1 (
    id int primary key,
    price int,
    item_id int,
    customer_id int
) WITH ( 
    connector = 'kafka',
    topic = 'topic_1',
    ...
) FORMAT PLAIN ENCODE JSON;

CREATE SINK orders_sink0 FROM orders_s0 INTO orders;
CREATE SINK orders_sink1 FROM orders_s1 INTO orders;

如果您不想要其中一个 topic，可以删除。

DROP SINK orders_sink0;

另请参阅

CREATE SINK — 创建到外部目标的 Sink。

DROP SINK — 删除 Sink。

SHOW CREATE SINK — 显示用于创建 sink 的 SQL 语句。