Hello everyone! I want to implement a streaming algorithm like Misa-Gries or Space Saving in Flink. The goal is to maintain the heavy hitters for my (possibly unbounded) input streams throughout all the time my app runs. More precisely, I want to have a non-stop running task that runs the Space Saving algorithm and updates a data structure that should be accessible by other tasks like map, flatmap of my Flink application at ad-hoc times. Although I am not so sure of how I can achieve the aforementioned goal.
First is it possible to have a structure in my main function that is updated by a task at all times and to be also accesible by others transformations at ad-hoc times?? Any ideas on how I can implement the above are more than welcome. Thanks in advance. Best, Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
