Hi, For these types of use cases, folks will generally make use of the Global Window which is -/+ inf and Timers. Some key considerations when using the Global Window:
1- GC is not done by the system as the window will never close. 2- There are no order guarantees, so you will often need to make use of looping timer <https://beam.apache.org/blog/looping-timers/>patterns. Cheers Reza On Thu, 26 Jan 2023 at 00:09, Vignesh Kumar Kathiresan via user < user@beam.apache.org> wrote: > Hi Community, > > I am new to beam coming from flink. In flink state can be scoped to only > key. A datasteam(similar to Pcollections in beam) can be converted to a > keyed data stream. And a process function on this keyed stream can access > state scoped to only key. It also has state scoped to key+window. In beam > though I see only state scoped to key+window combination. Is my > understanding correct? How are use cases using state scoped to key without > windows solved in beam. > > thanks > Vignesh >
