This repository contains a collection of Data Stream Processing applications implemented using the WindFlow library. WindFlow is a C++17 library for parallel stream processing on shared-memory architectures featuring multi-core CPUs and GPU devices. Further information on the usage and the operators provided by the WindFlow API can be found in the official documentation.
Two more implementations of these applications have been provided using Apache Storm and Apache Flink frameworks. The code can be found respectively in the storm-applications repository and in the flink-applications repository.
In order to run the applications contained in this project, the following dependencies are needed:
- GCC (GNU Compiler Collection) version >= 7.2
- WindFlow library version 1.0.0 -> see here
- FastFlow library version >= 3.0 -> see here
- ALGLIB library version 3.15.0 (released 2019/02/21) -> it has been already included in this project. More details about the library can be found in the official site. In the context of this project, the functionalities contained in the Descriptive Statistics package have been used.
- GDAL library version 2.4.0 (released 2018/12/14) -> see here