Hi all, Data stream windows are not yet supported in statefun, but it seems like the main motivation here is to purge old edges? If this is the case perhaps we need to integrate state TTL [1] into persisted values/persistedtables.
An alternative approach would be to implement a thumbling window per vertex (a stateful function instance) by sending to itself a delayed message [2]. When that specific delayed message arrives you would have to purge the oldest edges by examining the edges in state. I hope it helps, Igal. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/state.html#state-time-to-live-ttl [2] https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.0/sdk/java.html#sending-delayed-messages On Wednesday, May 6, 2020, Oytun Tez <oy...@motaword.com> wrote: > Oops – will follow the thread 🙊 > > > -- > > [image: MotaWord] > Oytun Tez > M O T A W O R D | CTO & Co-Founder > oy...@motaword.com > > <https://www.motaword.com/blog> > > > On Wed, May 6, 2020 at 5:37 PM m@xi <makisnt...@gmail.com> wrote: > >> Hello Tez, >> >> With all the respect, I doubt your answer is related the question. >> >> *Just to re-phase a bit*: Assuming we use SF for our application, how can >> we >> apply window logic when a function does some processing? *Is there a >> proper >> way?* >> >> @*Igal*: we would very much appreciate your answer. :) >> >> Best, >> Max >> >> >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> >
