Skip to content

Commit b6c6dc0

Browse files
XenosKXenosKHisoka-X
authored
[Feature][Connector-V2]Jdbc chunk split add snapshotSplitColumn config #7794 (#7840)
Co-authored-by: XenosK <xiangqiang.kong@sunmi.com> Co-authored-by: Jia Fan <fanjiaeminem@qq.com>
1 parent 1c52715 commit b6c6dc0

File tree

22 files changed

+123
-15
lines changed

22 files changed

+123
-15
lines changed

‎docs/en/connector-v2/source/MySQL-CDC.md‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -169,14 +169,14 @@ When an initial consistent snapshot is made for large databases, your establishe
169169

170170
## Source Options
171171

172-
| Name | Type | Required | Default | Description |
172+
| Name | Type | Required | Default | Description |
173173
|------------------------------------------------|----------|----------|---------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
174174
| base-url | String | Yes | - | The URL of the JDBC connection. Refer to a case: `jdbc:mysql://localhost:3306:3306/test`. |
175175
| username | String | Yes | - | Name of the database to use when connecting to the database server. |
176176
| password | String | Yes | - | Password to use when connecting to the database server. |
177177
| database-names | List | No | - | Database name of the database to monitor. |
178178
| table-names | List | Yes | - | Table name of the database to monitor. The table name needs to include the database name, for example: `database_name.table_name` |
179-
| table-names-config | List | No | - | Table config list. for example: [{"table": "db1.schema1.table1","primaryKeys":["key1"]}] |
179+
| table-names-config | List | No | - | Table config list. for example: [{"table": "db1.schema1.table1","primaryKeys": ["key1"],"snapshotSplitColumn": "key2"}] |
180180
| startup.mode | Enum | No | INITIAL | Optional startup mode for MySQL CDC consumer, valid enumerations are `initial`, `earliest`, `latest` and `specific`. <br/> `initial`: Synchronize historical data at startup, and then synchronize incremental data.<br/> `earliest`: Startup from the earliest offset possible.<br/> `latest`: Startup from the latest offset.<br/> `specific`: Startup from user-supplied specific offsets. |
181181
| startup.specific-offset.file | String | No | - | Start from the specified binlog file name. **Note, This option is required when the `startup.mode` option used `specific`.** |
182182
| startup.specific-offset.pos | Long | No | - | Start from the specified binlog file position. **Note, This option is required when the `startup.mode` option used `specific`.** |

‎docs/en/connector-v2/source/Oracle-CDC.md‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -220,15 +220,15 @@ exit;
220220

221221
## Source Options
222222

223-
| Name | Type | Required | Default | Description |
223+
| Name | Type | Required | Default | Description |
224224
|------------------------------------------------|----------|----------|---------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
225225
| base-url | String | Yes | - | The URL of the JDBC connection. Refer to a case: `idbc:oracle:thin:datasource01:1523:xe`. |
226226
| username | String | Yes | - | Name of the database to use when connecting to the database server. |
227227
| password | String | Yes | - | Password to use when connecting to the database server. |
228228
| database-names | List | No | - | Database name of the database to monitor. |
229229
| schema-names | List | No | - | Schema name of the database to monitor. |
230230
| table-names | List | Yes | - | Table name of the database to monitor. The table name needs to include the database name, for example: `database_name.table_name` |
231-
| table-names-config | List | No | - | Table config list. for example: [{"table": "db1.schema1.table1","primaryKeys":["key1"]}] |
231+
| table-names-config | List | No | - | Table config list. for example: [{"table": "db1.schema1.table1","primaryKeys": ["key1"],"snapshotSplitColumn": "key2"}] |
232232
| startup.mode | Enum | No | INITIAL | Optional startup mode for Oracle CDC consumer, valid enumerations are `initial`, `earliest`, `latest` and `specific`. <br/> `initial`: Synchronize historical data at startup, and then synchronize incremental data.<br/> `earliest`: Startup from the earliest offset possible.<br/> `latest`: Startup from the latest offset.<br/> `specific`: Startup from user-supplied specific offsets. |
233233
| startup.specific-offset.file | String | No | - | Start from the specified binlog file name. **Note, This option is required when the `startup.mode` option used `specific`.** |
234234
| startup.specific-offset.pos | Long | No | - | Start from the specified binlog file position. **Note, This option is required when the `startup.mode` option used `specific`.** |

0 commit comments

Comments
 (0)