Hello, I have a window processing 10 objects at a time, and creating 1 as a result. The problem is in order to create that object I need the object from the previous window.
I'm doing this: stream .keyBy(...some key...) .countWindow(10, 1) .apply(...creates an element A...) .keyBy(...same key as above...) .countWindow(2, 1) .apply(...updates A with the value of the previous element A...) .addSink(...) Probably there is a way to retrieve the last collected object inside the first .apply(), or to cache it somehow. Is there a better way to achieve the same? How inefficient is this? Regards, Matt
