State 0点清除的问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

State 0点清除的问题

ゞ野蠻遊戲χ
大家好:       我想问下,在ProcessAllWindowFunction中,在每天的0点清除state如何清除?


Thanks
嘉治
Reply | Threaded
Open this post in threaded view
|

Re: State 0点清除的问题

Congxian Qiu
Hi
如果你需要精确的控制每天 0 点清除  state 的话,或许你可以考虑使用 processFunction[1], 然后自己使用 timer
实现相关逻辑

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/stream/operators/process_function.html
Best,
Congxian


ゞ野蠻遊戲χ <[hidden email]> 于2020年7月14日周二 下午1:10写道:

> 大家好:&nbsp; &nbsp; &nbsp;
> &nbsp;我想问下,在ProcessAllWindowFunction中,在每天的0点清除state如何清除?
>
>
> Thanks
> 嘉治