跳到主要内容
版本:2.3.10

Druid

Druid 接收器连接器

描述

一个使用向 Druid 发送消息的接收器插件

关键特性

数据类型映射

SeaTunnel 数据类型Druid 数据类型
TINYINTLONG
SMALLINTLONG
INTLONG
BIGINTLONG
FLOATFLOAT
DOUBLEDOUBLE
DECIMALDOUBLE
STRINGSTRING
BOOLEANSTRING
TIMESTAMPSTRING

选项

名称类型必需默认值
coordinatorUrlstring-
datasourcestring-
batchSizeint10000
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
ChangeCommitVersion
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6ee2.3.10
[improve] update Druid connector config option (#8594)https://github.com/apache/seatunnel/commit/07a2288a22.3.10
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef800012.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d032.3.9
[Improve][Connector] Add multi-table sink option check (#7360)https://github.com/apache/seatunnel/commit/2489f64462.3.7
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)https://github.com/apache/seatunnel/commit/c4ca741222.3.6
[Feature][Druid]Support multi table for druid sink (#7023)https://github.com/apache/seatunnel/commit/476d492162.3.6
[Feature][Connector] Add druid sink connector (#6346)https://github.com/apache/seatunnel/commit/d7fa9afdf2.3.6