Tablestore

Tablestore 数据接收器

描述

用于将数据写入 Tablestore

主要特性

• exactly-once

选项

名称	类型	是否必填	默认值
end_point	string	是	-
instance_name	string	是	-
access_key_id	string	是	-
access_key_secret	string	是	-
table	string	是	-
primary_keys	array	是	-
batch_size	string	否	25
common-options	config	否	-

end_point [string]

endPoint 用于写入Tablestore。

instanceName [string]

Tablestore 的实例名称。

access_key_id [string]

Tablestore 访问的id。

access_key_secret [string]

Tablestore 访问的密钥。

table [string]

Tablestore的表。

primaryKeys [array]

Tablestore 的主键。

common 选项 [ config ]

Sink插件常用参数，请参考[Sink common Options]（../sink-common-options.md）了解详细信息。

示例

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"]
  }

变更日志

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