Skip to main content
Version: 2.3.10

Druid

Druid sink connector

Description

Write data to Druid

Key features

Data Type Mapping

SeaTunnel Data TypeDruid Data Type
TINYINTLONG
SMALLINTLONG
INTLONG
BIGINTLONG
FLOATFLOAT
DOUBLEDOUBLE
DECIMALDOUBLE
STRINGSTRING
BOOLEANSTRING
TIMESTAMPSTRING

Options

nametyperequireddefault value
coordinatorUrlstringyes-
datasourcestringyes-
batchSizeintno10000
common-optionsno-

coordinatorUrl [string]

The coordinatorUrl host and port of Druid, example: "myHost:8888"

datasource [string]

The datasource name you want to write, example: "seatunnel"

batchSize [int]

The number of rows flushed to Druid per batch. Default value is 1024.

common options

Sink plugin common parameters, please refer to Sink Common Options for details

Example

Simple example:

sink {
Druid {
coordinatorUrl = "testHost:8888"
datasource = "seatunnel"
}
}

Use placeholders get upstream table metadata example:

sink {
Druid {
coordinatorUrl = "testHost:8888"
datasource = "${table_name}_test"
}
}

Changelog

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