Re: Firing timers on ProcessWindowFunction

2019-12-02 Thread Avi Levi
Thanks Alexander, Will do. Cheers On Mon, Dec 2, 2019 at 3:23 PM Alexander Fedulov wrote: > *This Message originated outside your organization.* > -- > Hi Avi, > > In this situation I would propose to step back and use a lower level API > - ProcessFunction. You can

Re: Firing timers on ProcessWindowFunction

2019-12-02 Thread Avi Levi
I think the only way to do this is to add keyed operator down the stream that will hold the global state. not ideal but I don't see any other option On Mon, Dec 2, 2019 at 1:43 PM Avi Levi wrote: > Hi Vino, > I have a global state that I need to mutate every X hours (e.g clean that > state or up

Re: Firing timers on ProcessWindowFunction

2019-12-02 Thread Avi Levi
Hi Vino, I have a global state that I need to mutate every X hours (e.g clean that state or update its value) . I thought that there might be an option to set a timer user the timerService with it's own time interval detached from the window interval interval . On Mon, Dec 2, 2019 at 10:59 AM vino

Re: Firing timers on ProcessWindowFunction

2019-12-02 Thread vino yang
Hi Avi, Firstly, let's clarify that the "timer" you said is the timer of the window? Or a timer you want to register to trigger some action? Best, Vino Avi Levi 于2019年12月2日周一 下午4:11写道: > Hi, > Is there a way to fire timer in a ProcessWindowFunction ? I would like to > mutate the global state

Firing timers on ProcessWindowFunction

2019-12-02 Thread Avi Levi
Hi, Is there a way to fire timer in a ProcessWindowFunction ? I would like to mutate the global state on a timely basis.