Skip to content

Update mysql-sink.md #527

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
yangsishu merged 1 commit into from
Dec 23, 2021
Merged

Update mysql-sink.md #527

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions docs/connectors/mysql/mysql-sink.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ mysql5.x
<br />

- **column**
- 描述：目的表需要写入数据的字段,字段之间用英文逗号分隔。例如: "column": ["id","name","age"]
- 描述：目的表需要写入数据的字段。例如: "column": [{"name":"id",type:"varchar"}]
- 必选：是
- 参数类型：List
- 默认值：无
Expand All @@ -92,7 +92,7 @@ mysql5.x
- 默认值：无
<br />

- **writeMode**
- **mode**
- 描述：控制写入数据到目标表采用 insert into 或者 replace into 或者 ON DUPLICATE KEY UPDATE 语句
- 必选：是
- 所有选项：insert/replace/update
Expand All @@ -104,7 +104,7 @@ mysql5.x
- 描述：一次性批量提交的记录数大小，该值可以极大减少FlinkX与数据库的网络交互次数，并提升整体吞吐量。但是该值设置过大可能会造成FlinkX运行进程OOM情况
- 必选：否
- 参数类型：int
- 默认值：1024
- 默认值：1
<br />

- **updateKey**
Expand All @@ -113,8 +113,8 @@ mysql5.x
- 如果此参数为空，并且写入模式为update和replace时，应用会自动获取数据库中的唯一索引；
- 如果数据表没有唯一索引，但是写入模式配置为update和replace，应用会以insert的方式写入数据；
- 必选：否
- 参数类型：Map<String,List>
- 示例："updateKey": {"key": ["id"]}
- 参数类型：List<String>
- 示例："updateKey": ["id"]
- 默认值：无
<br />

Expand Down