​
syntax

CREATE SINK [ IF NOT EXISTS ] sink_name INTO table_name [ ( col_name [ , ... ] ) ]
[FROM sink_from | AS select_query]

​
Parameters

Parameter or clauseDescription
sink_nameThe 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_nameThe corresponding table columns in the sink result. For those columns not listed, it will be inserted as the default value defined in the table.

NOTE

A table without a primary key can only accept the append-only sink.

NOTE

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.

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 INTO orders FROM orders_s0;
CREATE SINK orders_sink1 INTO orders FROM orders_s1;

If you don’t want one of the topics, you can drop it.

DROP SINK orders_sink0;

​
See also

CREATE SINK

Create a sink into an external target

DROP SINK

Remove a sink

SHOW CREATE SINK

Show the SQL statement used to create a sink

Was this page helpful?

CREATE SECRETCREATE SINK