Druid
Druid sink connector
Descriptionâ
Write data to Druid
Key featuresâ
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â
next versionâ
- Add Druid sink connector