This repository contains a collection of Data Stream Processing applications implemented with Apache Storm. Applications can be run in local mode, further information can be found in each application README and in the official documentation. In order to improve performance, Storm's reliability mechanism has been deactivated by not tracking the tuple tree for spout tuples. Hence, tuples downstream in the topology are emitted as unanchored tuples, meaning that even if they are not acked they won't cause any spout tuples to fail. More details about Storm's guaranteed message processing can be found in the official documentation.
This work is based upon briskstream project and a collection of real-time applications.
Two more implementations of these applications have been provided: the first one using Apache Flink, which can be found in the flink-applications repository, and the second one using WindFlow C++17 library, which 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
- Java JDK version 1.8 -> see here
- OSGeo GeoTools library version 11.1 -> see here