THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 |
TODO:
- Use validation method (org.apache.commons.validator.routines.InetAddressValidator) instead of regex check
...
References:
- Apache StreamPipes Documentation: https://streampipes.apache.org/docs/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake/