Sink plugin: InfluxDB [Flink]
Write data to InfluxDB.
name | type | required | default value |
---|---|---|---|
server_url | String | yes | - |
username | String | no | - |
password | String | no | - |
database | String | yes | - |
measurement | String | yes | - |
tags | List<String> | yes | - |
fields | 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 Tag in InfluxDB.
List<String>
]The list of Field in InfluxDB.
Int
]The parallelism of an individual operator, for InfluxDbSink
InfluxDbSink { server_url = "http://127.0.0.1:8086/" database = "influxdb" measurement = "m" tags = ["country", "city"] fields = ["count"] }
InfluxDbSink { server_url = "http://127.0.0.1:8086/" username = "admin" password = "password" database = "influxdb" measurement = "m" tags = ["country", "city"] fields = ["count"] }