Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
org.apache.streampipes.sinks.internal.jvm.datalake

When using the Data Lake sink, the incoming events are stored in an InfluxDB.

Implementation

org.apache.streampipes.sinks.internal.jvm.datalake

The concrete implementation comprises a Data Lake class, a Data Lake Controller class, a Data Lake InfluxDB Client class and a Data Lake Parameters class. The code is basically the same as for the InfluxDB sink (org.apache.streampipes.sinks.databases.jvm.influxdb).

...