Source plugin: Druid [Flink]
Read data from Apache Druid.
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 | - |
String
]The URL of JDBC of Apache Druid.
String
]The DataSource name in Apache Druid.
String
]The start date of DataSource, for example, '2016-06-27'
, '2016-06-27 00:00:00'
, etc.
String
]The end date of DataSource, for example, '2016-06-28'
, '2016-06-28 00:00:00'
, etc.
List<String>
]These columns that you want to query of DataSource.
Source Plugin common parameters, refer to Source Plugin for details
Int
]The parallelism of an individual operator, for DruidSource
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"] }