Skip to content

Latest commit

 

History

History
58 lines (37 loc) · 1.43 KB

Druid.md

File metadata and controls

58 lines (37 loc) · 1.43 KB

Druid

Source plugin: Druid [Flink]

Description

Read data from Apache 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"]
}