回复：如何在窗口关闭的时候清除状态

Sat, 04 Jul 2020 05:29:28 -0700 

设置一下状态过期的时间呢


| |
JasonLee
|
|
邮箱：[email protected]
|

Signature is customized by Netease Mail Master

在2020年07月03日 14:02，[email protected] 写道：
大家好，我有一个需求，我在ProcessWindowFunction算子中定义了一个valueState，我希望在窗口关闭的时候能够将状态清理。我应该在哪里清理呢？
1.刚开始我选择在ProcessWindowFunction算子的process方法中清理，但是这里会有一个问题，我事件时间窗口开1天，我写了一个trigger，每隔一个小时输出一次结果。
如果我在process方法中清理，每隔一个小时就会被清理，而valueState中存的是我的中间结果，应该在窗口关闭的时候被清理（即一天之后）。这应该怎么办呢？



[email protected]

回复