Flink CDC系列之:学习理解核心概念——Data Sink
- sink
- 参数
- 示例
sink
数据接收器用于应用架构更改并将更改数据写入外部系统。
数据接收器可以同时写入多个表。
参数
为了描述数据接收器,需要以下内容:
参数 | 含义 | 可选/必需 |
---|---|---|
type | sink的类型,例如 doris 或 starrocks。 | 必需 |
name | 接收器的名称,由用户定义(提供默认值)。 | 可选 |
数据源配置 | 构建数据接收器的配置,例如连接配置和接收器表属性。 | 可选 |
示例
我们可以使用这个 yaml 文件来定义 doris 接收器:
sink:type: dorisname: doris-sink # Optional parameter for description purposefenodes: 127.0.0.1:8030username: rootpassword: ""table.create.properties.replication_num: 1 # Optional parameter for advanced functionalities