Re:Re: 如何在窗口关闭的时候清除状态

2020-07-06 Thread flink小猪
[1].设置TTL应该也能达到相同的效果,我还是希望在窗口关闭的时候能够做一些自定义的操作(比如这里的清除状态,也许之后会有其他的操作TTL就不一样好用了) [2].KeyedProcessFunction,应该自己注册定时器把,在我的代码里面是timeWIndow().trigger().process(), ProcessWindowFunction方法我只需要处理逻辑即可,不需要管定时的窗口。 在 2020-07-05 11:56:03,"Congxian Qiu" 写道: >看上去这个需求是 一天的窗口,每个小时都 trigger 一次,希望 s

Re: Re:Re: 如何在窗口关闭的时候清除状态

2020-07-08 Thread Yun Tang
/flink/flink-docs-stable/dev/stream/state/state.html#state-time-to-live-ttl 祝好 唐云 From: flink小猪 <18579099...@163.com> Sent: Tuesday, July 7, 2020 10:44 To: user-zh@flink.apache.org Subject: Re:Re: 如何在窗口关闭的时候清除状态 [1].设置TTL应该也能达到相同的效果,我还是希望在窗口关闭的时候能够做一些自定义的操作