Druid

Description

Read data from Apache Druid.

tip

Engine Supported and plugin name

• Spark
• Flink: Druid

Options

name	type	required	default value
jdbc_url	String	yes	-
datasource	String	yes	-
start_date	String	no	-
end_date	String	no	-
columns	List<String>	no	*
parallelism	Int	no	-

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"]
}