跳到主要内容
版本: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