Hello, I am using beam on dataflow with java sdk 2.19.0. I have a use case where I need to collect some messages in a short window of few seconds to 1 minute, update state (stateful processing of beam) and carry forward this state information to next window and use this to initialize state of next window i.e something like following:
[image: image.png] Since windows are very short, I don't want to write to some external DB on window expiry and read from DB in next window. Is it possible to carry forward state information from one window to next ? Or any other suggestion to achieve this? Thanks and regards Mohil
