我有一种情况,如果第二个事件在x秒内没有跟随第一个事件,那么我必须更改状态。例如用户在100分钟内未注销,则认为他处于无效状态。如何使用当前的模式操作进行设计?

最佳答案

目前这是不可能的。解决方案将是有一个超时处理程序,只要事件序列由于超出了定义的时间窗口而被丢弃,就会触发该超时处理程序。 JIRA问题已经存在,它可以跟踪timeout handler实现。

关于apache-flink - 不遵循的Apache Flink CEP模式操作,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/36573715/

10-12 13:53