Hi, I want to do windowed processing in each function when using Stateful Functions. Is this possible? Some pseudo code would be very helpful!
Some more context: I'm having a stream of edges as input. I want to window these and save the graph representation (either as edge list, adjacency list, or CSR) in a distributed way using state. Since doing this for the entire edge stream would cost far too much memory, I want to only save the state of the graph within the window. How could I achieve this? Thanks! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
