This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 096ce9d75b1 [typo](doc)Add flink cdc partial column update column
(#26402)
096ce9d75b1 is described below
commit 096ce9d75b189069a63a79bff08d448f9250bf6c
Author: caoliang-web <[email protected]>
AuthorDate: Fri Nov 24 17:10:33 2023 +0800
[typo](doc)Add flink cdc partial column update column (#26402)
---
docs/en/docs/ecosystem/flink-doris-connector.md | 45 ++++++++++++++++++++++
docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 44 +++++++++++++++++++++
2 files changed, 89 insertions(+)
diff --git a/docs/en/docs/ecosystem/flink-doris-connector.md
b/docs/en/docs/ecosystem/flink-doris-connector.md
index 74618c89dee..9e06416d769 100644
--- a/docs/en/docs/ecosystem/flink-doris-connector.md
+++ b/docs/en/docs/ecosystem/flink-doris-connector.md
@@ -417,6 +417,51 @@ WITH (
insert into doris_sink select id,name from cdc_mysql_source;
```
+## Example of using FlinkSQL to access and implement partial column updates
through CDC
+
+```sql
+-- enable checkpoint
+SET 'execution.checkpointing.interval' = '10s';
+
+CREATE TABLE cdc_mysql_source (
+ id int
+ ,name STRING
+ ,bank STRING
+ ,age int
+ ,PRIMARY KEY (id) NOT ENFORCED
+) WITH (
+ 'connector' = 'mysql-cdc',
+ 'hostname' = '127.0.0.1',
+ 'port' = '3306',
+ 'username' = 'root',
+ 'password' = 'password',
+ 'database-name' = 'database',
+ 'table-name' = 'table'
+);
+
+CREATE TABLE doris_sink (
+ id INT,
+ name STRING,
+ bank STRING,
+ age int
+)
+WITH (
+ 'connector' = 'doris',
+ 'fenodes' = '127.0.0.1:8030',
+ 'table.identifier' = 'database.table',
+ 'username' = 'root',
+ 'password' = '',
+ 'sink.properties.format' = 'json',
+ 'sink.properties.read_json_by_line' = 'true',
+ 'sink.properties.columns' = 'id,name,bank,age',
+ 'sink.properties.partial.columns' = 'true' --Enable partial column updates
+);
+
+
+insert into doris_sink select id,name,bank,age from cdc_mysql_source;
+
+```
+
## Use FlinkCDC to access multi-table or whole database example
### grammar
diff --git a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
index 8447083620b..144605ce9a2 100644
--- a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
+++ b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
@@ -420,6 +420,50 @@ WITH (
);
insert into doris_sink select id,name from cdc_mysql_source;
+```
+## 使用FlinkSQL通过CDC接入并实现部分列更新示例
+
+```sql
+-- enable checkpoint
+SET 'execution.checkpointing.interval' = '10s';
+
+CREATE TABLE cdc_mysql_source (
+ id int
+ ,name STRING
+ ,bank STRING
+ ,age int
+ ,PRIMARY KEY (id) NOT ENFORCED
+) WITH (
+ 'connector' = 'mysql-cdc',
+ 'hostname' = '127.0.0.1',
+ 'port' = '3306',
+ 'username' = 'root',
+ 'password' = 'password',
+ 'database-name' = 'database',
+ 'table-name' = 'table'
+);
+
+CREATE TABLE doris_sink (
+ id INT,
+ name STRING,
+ bank STRING,
+ age int
+)
+WITH (
+ 'connector' = 'doris',
+ 'fenodes' = '127.0.0.1:8030',
+ 'table.identifier' = 'database.table',
+ 'username' = 'root',
+ 'password' = '',
+ 'sink.properties.format' = 'json',
+ 'sink.properties.read_json_by_line' = 'true',
+ 'sink.properties.columns' = 'id,name,bank,age',
+ 'sink.properties.partial.columns' = 'true' -- 开启部分列更新
+);
+
+
+insert into doris_sink select id,name,bank,age from cdc_mysql_source;
+
```
## 使用FlinkCDC接入多表或整库示例
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
