import ChangeLog from ‘../changelog/connector-druid.md’;

Druid

Druid sink connector

Description

Write data to Druid

Key features

• [ ] exactly-once
• [x] support multiple table write

Data Type Mapping

SeaTunnel Data Type	Druid Data Type
TINYINT	LONG
SMALLINT	LONG
INT	LONG
BIGINT	LONG
FLOAT	FLOAT
DOUBLE	DOUBLE
DECIMAL	DOUBLE
STRING	STRING
BOOLEAN	STRING
TIMESTAMP	STRING

Options

name	type	required	default value
coordinatorUrl	string	yes	-
datasource	string	yes	-
batchSize	int	no	10000
common-options		no	-

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