As echauchot@ mentioned, it will make it easier and error-free.
On Mon, Mar 19, 2018 at 11:59 PM Romain Manni-Bucau <rmannibu...@gmail.com> wrote: > Hi Huygaa, > > Cant it be predefined timers? > > Romain > > Le 20 mars 2018 00:52, "Huygaa Batsaikhan" <bat...@google.com> a écrit : > > Hi everyone, I am working on BEAM-1589 > <https://issues.apache.org/jira/browse/BEAM-1589>. In short, currently, > there is no default way of saving/flushing state before a window is garbage > collected. > > My current plan is to provide a method annotation, @OnWindowExpiration, > which allows user-provided callback function to be executed before garbage > collection. This annotation behaves very similar to @OnTimer, therefore, > implementation will mostly be a copy of OnTimer code. Let me know if you > have any considerations and suggestions. > > Here is an example usage: > ``` > @OnWindowExpiration > public void myCleanupFunction(OnWindowExpirationContext c, State state) { > c.output(state.read()); > } > ``` > > Thanks, Huygaa > > >
