Source plugin: InfluxDb [Flink]
Read data from InfluxDB.
name | type | required | default value |
---|---|---|---|
server_url | String | yes | - |
username | String | no | - |
password | String | no | - |
database | String | yes | - |
measurement | String | yes | - |
fields | List<String> | yes | - |
field_types | List<String> | yes | - |
parallelism | Int | no | - |
String
]The URL of InfluxDB Server.
String
]The username of InfluxDB Server.
String
]The password of InfluxDB Server.
String
]The DataSource name in InfluxDB.
String
]The Measurement name in InfluxDB.
List<String>
]The list of Field in InfluxDB.
List<String>
]The list of Field Types in InfluxDB.
Int
]The parallelism of an individual operator, for InfluxDbSource.
InfluxDbSource { server_url = "http://127.0.0.1:8086/" database = "influxdb" measurement = "m" fields = ["time", "temperature"] field_types = ["STRING", "DOUBLE"] }
InfluxDbSource { server_url = "http://127.0.0.1:8086/" username = "admin" password = "password" database = "influxdb" measurement = "m" fields = ["time", "temperature"] field_types = ["STRING", "DOUBLE"] }