Druid
Druid 接收器连接器
描述
一个使用向 Druid 发送消息的接收器插件
关键特性
数据类型映射
SeaTunnel 数据类型 | Druid 数据类型 |
---|---|
TINYINT | LONG |
SMALLINT | LONG |
INT | LONG |
BIGINT | LONG |
FLOAT | FLOAT |
DOUBLE | DOUBLE |
DECIMAL | DOUBLE |
STRING | STRING |
BOOLEAN | STRING |
TIMESTAMP | STRING |
选项
名称 | 类型 | 必需 | 默认值 |
---|---|---|---|
coordinatorUrl | string | 是 | - |
datasource | string | 是 | - |
batchSize | int | 否 | 10000 |
common-options | 否 | - |
coordinatorUrl [string]
Druid的协调器URL主机和端口,示例: "myHost:8888"
datasource [string]
要写入的数据源名称,示例: "seatunnel"
batchSize [int]
每批刷新为Druid的行数。默认值为 1024
.
common options
Sink插件常用参数,详见 Sink Common Options for details
示例
简单的例子:
sink {
Druid {
coordinatorUrl = "testHost:8888"
datasource = "seatunnel"
}
}
使用占位符获取上游表元数据示例:
sink {
Druid {
coordinatorUrl = "testHost:8888"
datasource = "${table_name}_test"
}
}
变更日志
Change Log
Change | Commit | Version |
---|---|---|
[Improve] restruct connector common options (#8634) | https://github.com/apache/seatunnel/commit/f3499a6ee | 2.3.10 |
[improve] update Druid connector config option (#8594) | https://github.com/apache/seatunnel/commit/07a2288a2 | 2.3.10 |
[Improve][dist]add shade check rule (#8136) | https://github.com/apache/seatunnel/commit/51ef80001 | 2.3.9 |
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03 | 2.3.9 |
[Improve][Connector] Add multi-table sink option check (#7360) | https://github.com/apache/seatunnel/commit/2489f6446 | 2.3.7 |
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131) | https://github.com/apache/seatunnel/commit/c4ca74122 | 2.3.6 |
[Feature][Druid]Support multi table for druid sink (#7023) | https://github.com/apache/seatunnel/commit/476d49216 | 2.3.6 |
[Feature][Connector] Add druid sink connector (#6346) | https://github.com/apache/seatunnel/commit/d7fa9afdf | 2.3.6 |