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 <avi.l...@bluevoyant.com> wrote: > 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 yang <yanghua1...@gmail.com> wrote: > >> *This Message originated outside your organization.* >> ------------------------------ >> 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 <avi.l...@bluevoyant.com> 于2019年12月2日周一 下午4:11写道： >> >>> Hi, >>> Is there a way to fire timer in a ProcessWindowFunction ? I would like >>> to mutate the global state on a timely basis. >>> >>>
