ProcessWindowFunction中状态的TTL



我想在processwindow函数中设置状态的TTL。此状态在多个窗口之间共享。此TTL需要基于事件本身中的一个属性。所以我无法计算状态描述符中的TTL。此外,processwindow函数中不支持onTimer函数。

还有其他方法可以做到这一点吗?

如果生存时间必须作为事件本身的函数计算,则不能使用状态TTL机制。

唯一的替代方案是使用带有KeyedProcessFunction的计时器,而不是使用窗口API。flink文档中有一个示例:https://ci.apache.org/projects/flink/flink-docs-stable/learn-flink/event_driven.html#example

相关内容

  • 没有找到相关文章

最新更新