跳到主要内容
版本：2.3.12

Druid

Druid 接收器连接器

描述​

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

关键特性​

数据类型映射​

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

选项​

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