一次只存在一个flink cep模式

ct3nt3jp  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(335)

一次是否可以为一个键设置一个模式。例如,我想检查是否在1分钟窗口内得到5个与where条件匹配的事件,如果在一分钟内得到10个这样的事件,我应该得到2个警报,但我得到6个警报。这是因为每一个事件都会触发一个新的模式。我们可以一次为一个键创建一个模式示例。

nwlls2ji

nwlls2ji1#

这听起来像你有类似的问题,我有:我不希望同一事件,以参加一个以上的滑动窗口。我可以通过使用aftermatchskipstrategy.skipcastlastEvent()实现这一点。这在1.4中提供。希望这有帮助!

相关问题