Skip to main content
Version: 2.3.8

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​

next version​

  • Add Druid sink connector