Druid

Druid sink connector

Description​

Write data to Druid

Key features​

• exactly-once

• support multiple table write

Data Type Mapping​

Nexus 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: "nexus"

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 = "nexus"
  }
}

Use placeholders get upstream table metadata example:

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