跳到主要内容
版本:2.1.2

Druid

Description

Read data from Apache Druid.

提示

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