THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The parameter class defines the necessary parameters for the configuration of the sink.
| parameter | description |
|---|---|
influxDbHost | hostname/URL of the InfluxDB instance. (including http(s)://) |
| influxDbPort | port of the InfluxDB instance |
| databaseName | name of the database where events will be stored |
| measureName | name of the Measurement where events will be stored (will be created if it does not exist) |
| user | username for the InfluxDB server |
| password | password for the InfluxDB server |
| timestampField | field which contains the required timestamp (field type = http://schema.org/DateTime) |
| batchSize | indicates how many events are written into a buffer, before they are written to the database |
| flushDuration | maximum waiting time for the buffer to fill the Buffer size before it will be written to the database in ms |
| dimensionProperties | list containing the tag fields (scope = dimension property) |
DataLake Controller Class
...
The measurement name and the timestamp field are derived from user input, the remaining parameters (except batch size and flush duration) from org.apache.streampipes.sinks.internal.jvm.config.SinksInternalJvmConfig. Batch size is fixed to 2000 events and flush duration is set to 500ms500 ms.
DataLake Class
The data lake class itself comprises a total of six methods and essentially controls the saving of events to the database. For this purpose, it uses the data lake InfluxDB client.
...