我想在processwindowfunction中设置状态的ttl。此状态在windows中共享。这个ttl需要基于事件本身的属性。所以我无法计算状态描述符中的ttl。此外，processwindowfunction中不支持ontimer函数。有没有其他方法可以达到这个目的？
ecbunoof1#
如果生存时间必须作为事件本身的函数来计算，那么就不能使用状态ttl机制。唯一的选择是使用带有 KeyedProcessFunction ，而不是使用windowapi。flink文档中有一个例子：https://ci.apache.org/projects/flink/flink-docs-stable/learn-flink/event_driven.html#example
KeyedProcessFunction
1条答案
按热度按时间ecbunoof1#
如果生存时间必须作为事件本身的函数来计算，那么就不能使用状态ttl机制。
唯一的选择是使用带有
KeyedProcessFunction，而不是使用windowapi。flink文档中有一个例子：https://ci.apache.org/projects/flink/flink-docs-stable/learn-flink/event_driven.html#example