THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
| method name | description |
|---|---|
| onInvocation | Starting starting the DataLakeInfluxDbClient, Registeringregistering and Initializinginitializing new measurement series in InfluxDB |
| onEvent | adding empty label field to incoming event and storing event in database |
| onDetach | stopping the DataLakeInfluxDbClient |
Image data, unlike events, is not stored directly in database but as Image files in a corresponding directory (writeToImageFile). In addition, the class contains two utility methods (registerAtDataLake and prepareString)
References:
- Apache StreamPipes Documentation: https://streampipes.apache.org/docs/docs/pe/org.apache.streampipes.sinks.internal.jvm.datalake/