This repository contains a collection of Data Stream Processing applications implemented with Apache Storm and adapted to be executed on Apache Flink by means of the Storm Compatibility API.
Applications can be run in local mode, further information can be found in each application README and in the official documentation.
The Storm version of the applications can be found in the storm-applications repository. One more implementation has been provided, using WindFlow C++17 library, and can be found in the windflow-applications repository.
In order to run the applications contained in this project, the following dependencies are needed:
- Apache Storm version 1.1.3 -> see here
- Apache Flink version 1.7.2 -> see here
- Java JDK version 1.8 -> see here
- OSGeo GeoTools library version 11.1 -> see here