CREATE SINK

使用 CREATE SINK 命令创建一个 sink。Sink 是一个外部目标，您可以将 RisingWave 中处理的数据发送到该目标。您可以从表、source 或物化视图创建一个 Sink。

如果您的目标是创建一个 Append-Only Sink，可以在创建要从中导出数据的物化视图时使用 emit-on-window-close 策略。关于该策略的详细信息，请参阅 Emit on window close。

句法

CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
WITH (
   connector='connector_name',
   connector_parameter = 'value', ...
)
[ FORMAT data_format ENCODE data_encode [ (
    format_parameter = 'value'
) ] ];

note

可选的 FORMAT data_format ENCODE data_encode 句法仅用于 Kafka、Kinesis 和 Pulsar 的 Sink。

支持的 sink

单击 sink 名称查看从 RisingWave 向 sink 中导出数据的 SQL 句法、选项和示例语句。

• Apache Doris
• Apache Iceberg
• AWS Kinesis
• Cassandra or ScyllaDB
• ClickHouse
• CockroachDB
• Delta Lake
• Elasticsearch
• Google BigQuery
• Kafka (Supports versions 3.1.0 or later)
• MySQL (Supports versions 5.7 and 8.0.x)
• NATS
• PostgreSQL
• Pulsar
• Redis
• StarRocks
• TiDB

另请参阅

DROP SINK — 删除 Sink。

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

CREATE SINK INTO — 创建导出到 RisingWave 的表中。

note

Timestamptz 值以 UTC 存储。

导出到下游时，timestamptz 的表示是可配置的。默认格式为 2023-11-11T18:30:09.453000Z。