THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Client class that connects to InfluxDB and writes events directly to database. Uses the Data Lake Parameters described above.
| method name | description |
|---|---|
| validate | checks |
whether |
the |
influxDbHost is |
valid | |
| connect | connects to the InfluxDB server, sets the database and initializes the batch-behaviour |
| databaseExists | checks whether the given database exists |
| createDatabase | creates a new database with the given name |
| save | saves an event to the connnected InfluxDB database |
| stop | shuts down the connection to the InfluxDB server |
...
References:
- Apache StreamPipes Documentation: https://streampipes.apache.org/docs/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake/