This is an automated email from the ASF dual-hosted git repository.
jiafengzheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new e7e551ffa7 [doc][fix]Sync job doc (#9790)
e7e551ffa7 is described below
commit e7e551ffa72d211b668661f067929887de6f708e
Author: jiafeng.zhang <zhang...@gmail.com>
AuthorDate: Fri May 27 12:56:19 2022 +0800
[doc][fix]Sync job doc (#9790)
binlog load documentation fix
---
.../Load/CREATE-SYNC-JOB.md | 39 ++++++++--------------
.../Load/CREATE-SYNC-JOB.md | 39 ++++++++--------------
2 files changed, 28 insertions(+), 50 deletions(-)
diff --git
a/docs/en/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
b/docs/en/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
index 950d407e66..633c4509f0 100644
---
a/docs/en/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
+++
b/docs/en/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
@@ -62,46 +62,35 @@ binlog_desc
```sql
FROM mysql_db.src_tbl INTO des_tbl
- [partitions]
[columns_mapping]
````
-
+
1. `mysql_db.src_tbl`
-
+
Specify the database and source table on the mysql side.
-
+
2. `des_tbl`
-
+
Specify the target table on the doris side. Only unique tables are
supported, and the batch delete function of the table needs to be enabled (see
the 'batch delete function' of help alter table for how to enable it).
-
- 3. `partitions`
-
- Specify in which partitions of the import destination table. If not
specified, it will be automatically imported into the corresponding partition.
-
- Example:
-
- ````
- PARTITION(p1, p2, p3)
- ````
-
+
4. `column_mapping`
-
+
Specifies the mapping relationship between the columns of the mysql
source table and the doris target table. If not specified, FE will default the
columns of the source table and the target table to one-to-one correspondence
in order.
-
+
The form col_name = expr is not supported for columns.
-
+
Example:
-
+
````
Suppose the target table column is (k1, k2, v1),
Change the order of columns k1 and k2
- COLUMNS(k2, k1, v1)
+ (k2, k1, v1)
Ignore the fourth column of the source data
- COLUMNS(k2, k1, v1, dummy_column)
+ (k2, k1, v1, dummy_column)
````
-
+
3. `binlog_desc`
Used to describe the remote data source, currently only one canal is
supported.
@@ -151,8 +140,8 @@ binlog_desc
````SQL
CREATE SYNC `test_db`.`job1`
(
- FROM `mysql_db`.`t1` INTO `test1` COLUMNS(k1, k2, v1) PARTITIONS (p1, p2),
- FROM `mysql_db`.`t2` INTO `test2` COLUMNS(k3, k4, v2) PARTITION p1
+ FROM `mysql_db`.`t1` INTO `test1` (k1, k2, v1) ,
+ FROM `mysql_db`.`t2` INTO `test2` (k3, k4, v2)
)
FROM BINLOG
(
diff --git
a/docs/zh-CN/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
b/docs/zh-CN/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
index a62eda8bf5..cff9e8df3f 100644
---
a/docs/zh-CN/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
+++
b/docs/zh-CN/sql-manual/sql-reference/Data-Manipulation-Statements/Load/CREATE-SYNC-JOB.md
@@ -62,46 +62,35 @@ binlog_desc
```sql
FROM mysql_db.src_tbl INTO des_tbl
- [partitions]
[columns_mapping]
```
-
+
1. `mysql_db.src_tbl`
-
+
指定mysql端的数据库和源表。
-
+
2. `des_tbl`
-
+
指定doris端的目标表，只支持Unique表，且需开启表的batch delete功能(开启方法请看help alter
table的'批量删除功能')。
-
- 3. `partitions`
-
- 指定导入目的表的哪些 partition 中。如果不指定，则会自动导入到对应的 partition 中。
-
- 示例：
-
- ```
- PARTITION(p1, p2, p3)
- ```
-
+
4. `column_mapping`
-
+
指定mysql源表和doris目标表的列之间的映射关系。如果不指定，FE会默认源表和目标表的列按顺序一一对应。
-
+
不支持 col_name = expr 的形式表示列。
-
+
示例：
-
+
```
假设目标表列为(k1, k2, v1)，
改变列k1和k2的顺序
- COLUMNS(k2, k1, v1)
+ (k2, k1, v1)
忽略源数据的第四列
- COLUMNS(k2, k1, v1, dummy_column)
+ (k2, k1, v1, dummy_column)
```
-
+
3. `binlog_desc`
用来描述远端数据源，目前仅支持canal一种。
@@ -151,8 +140,8 @@ binlog_desc
```SQL
CREATE SYNC `test_db`.`job1`
(
- FROM `mysql_db`.`t1` INTO `test1` COLUMNS(k1, k2, v1) PARTITIONS (p1,
p2),
- FROM `mysql_db`.`t2` INTO `test2` COLUMNS(k3, k4, v2) PARTITION p1
+ FROM `mysql_db`.`t1` INTO `test1` (k1, k2, v1),
+ FROM `mysql_db`.`t2` INTO `test2` (k3, k4, v2)
)
FROM BINLOG
(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
