Skip to main content
Version: 2.1.2

Druid

Description​

Read data from Apache Druid.

tip

Engine Supported and plugin name

  • Spark
  • Flink: Druid

Options​

nametyperequireddefault value
jdbc_urlStringyes-
datasourceStringyes-
start_dateStringno-
end_dateStringno-
columnsList<String>no*
parallelismIntno-

jdbc_url [String]​

The URL of JDBC of Apache Druid.

datasource [String]​

The DataSource name in Apache Druid.

start_date [String]​

The start date of DataSource, for example, '2016-06-27', '2016-06-27 00:00:00', etc.

end_date [String]​

The end date of DataSource, for example, '2016-06-28', '2016-06-28 00:00:00', etc.

columns [List<String>]​

These columns that you want to query of DataSource.

common options [string]​

Source Plugin common parameters, refer to Source Plugin for details

parallelism [Int]​

The parallelism of an individual operator, for DruidSource

Example​

DruidSource {
jdbc_url = "jdbc:avatica:remote:url=http://localhost:8082/druid/v2/sql/avatica/"
datasource = "wikipedia"
start_date = "2016-06-27 00:00:00"
end_date = "2016-06-28 00:00:00"
columns = ["flags","page"]
}