I am doing a benchmark in Flink, Storm, Spark for an iterative streaming
The goal is to make a window for a stream and do an iterative computation
Both Flink and Storm provides a window function with a list or iterator. But
I am not quite sure how to do this. Is it possible to get all the elements
in a window as a list or iterator or etc?
And the goal after this windowed computation is to do a reduce operation to
globally synchronized value.