ProbSlack is a probabilistic framework for analyzing late arrival of events in distributed stream processing systems. We have implemented a prototype of our framework on top of Apache Flink (1.4.0). Our prototype has been implemented by extending the process function of the Flink operators.
More details can be found in the following publication: Probabilistic Management of Events’ Late Arrival, Nicolo Rivetti, Nikos Zacheilas, Avigdor Gal and Vana Kalogeraki, Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems (DEBS), Hamilton, New Zealand, June 2018
For accessing the code and the datasets send an e-mail at: vana[*at*]aueb.gr or zacheilas[*at*]aueb.gr