Sink plugin: Druid [Flink]
Write data to Apache Druid.
name | type | required | default value |
---|---|---|---|
coordinator_url | String | yes | - |
datasource | String | yes | - |
timestamp_column | String | no | timestamp |
timestamp_format | String | no | auto |
timestamp_missing_value | String | no | - |
parallelism | Int | no | - |
String
]The URL of Coordinator service in Apache Druid.
String
]The DataSource name in Apache Druid.
String
]The timestamp column name in Apache Druid, the default value is timestamp
.
String
]The timestamp format in Apache Druid, the default value is auto
, it could be:
iso
posix
millis
micro
nano
auto
any Joda DateTimeFormat string
String
]The timestamp missing value in Apache Druid, which is used for input records that have a null or missing timestamp. The value of timestamp_missing_value
should be in ISO 8601 format, for example "2022-02-02T02:02:02.222"
.
Int
]The parallelism of an individual operator, for DruidSink
DruidSink { coordinator_url = "http://localhost:8081/" datasource = "wikipedia" }
DruidSink { coordinator_url = "http://localhost:8081/" datasource = "wikipedia" timestamp_column = "timestamp" timestamp_format = "auto" }
DruidSink { coordinator_url = "http://localhost:8081/" datasource = "wikipedia" timestamp_column = "timestamp" timestamp_format = "auto" timestamp_missing_value = "2022-02-02T02:02:02.222" }