Druid
Description
Read data from Apache Druid.
提示
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"]
}