⭐️
Tablestore
Tablestore sink connector
Description
Write data to Tablestore
Key features
Options
| name | type | required | default value |
|---|---|---|---|
| end_point | string | yes | - |
| instance_name | string | yes | - |
| access_key_id | string | yes | - |
| access_key_secret | string | yes | - |
| table | string | yes | - |
| primary_keys | array | yes | - |
| batch_size | string | no | 25 |
| common-options | config | no | - |
end_point [string]
endPoint to write to Tablestore.
instanceName [string]
The instanceName of Tablestore.
access_key_id [string]
The access id of Tablestore.
access_key_secret [string]
The access secret of Tablestore.
table [string]
The table of Tablestore.
primaryKeys [array]
The primaryKeys of Tablestore.
common options [ config ]
Sink plugin common parameters, please refer to Sink Common Options for details.
Example
Tablestore {
end_point = "xxxx"
instance_name = "xxxx"
access_key_id = "xxxx"
access_key_secret = "xxxx"
table = "sink"
primary_keys = ["pk_1","pk_2","pk_3","pk_4"]
}
Changelog
Change Log
| Change | Commit | Version |
|---|---|---|
| [Improve] restruct connector common options (#8634) | https://github.com/apache/seatunnel/commit/f3499a6eeb | dev |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03c | 2.3.9 |
| [Feature][Connector-V2][Tablestore] Support Source connector for Tablestore #7448 (#7467) | https://github.com/apache/seatunnel/commit/a7ca51b585 | 2.3.8 |
| [Improve][Common] Introduce new error define rule (#5793) | https://github.com/apache/seatunnel/commit/9d1b2582b2 | 2.3.4 |
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755) | https://github.com/apache/seatunnel/commit/8de7408100 | 2.3.4 |
| Support config column/primaryKey/constraintKey in schema (#5564) | https://github.com/apache/seatunnel/commit/eac76b4e50 | 2.3.4 |
| [Improve][Connector-V2] Remove scheduler in Tablestore sink (#5272) | https://github.com/apache/seatunnel/commit/8d6b07e466 | 2.3.3 |
| Merge branch 'dev' into merge/cdc | https://github.com/apache/seatunnel/commit/4324ee1912 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. | https://github.com/apache/seatunnel/commit/423b583038 | 2.3.1 |
| [improve][api] Refactoring schema parse (#4157) | https://github.com/apache/seatunnel/commit/b2f573a13e | 2.3.1 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd601051 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab166561 | 2.3.1 |
| [Hotfix][OptionRule] Fix option rule about all connectors (#3592) | https://github.com/apache/seatunnel/commit/226dc6a119 | 2.3.0 |
| [Improve][Connector-V2][TableStore] Unified excetion for TableStore sink connector (#3527) | https://github.com/apache/seatunnel/commit/7b264d7004 | 2.3.0 |
| [Feature][connector-v2] add tablestore source and sink (#3309) | https://github.com/apache/seatunnel/commit/ebebf0b633 | 2.3.0 |