Page History

...

• 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

In controller class, the model is declared for viewing and configuration in Pipeline Editor, and initializes sink on invocation of pipeline.

References:

• Apache StreamPipes Documentation: https://streampipes.apache.org/docs/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake/