cep中的java序列匹配语义

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

apache jira中存在一个问题:https://issues.apache.org/jira/browse/flink-3703. 它允许定义在找到匹配序列后匹配算法应继续的位置,并且有三种类型的行为: from first -继续保留所有事件以备将来匹配(即当前行为) after first -在第一个元素之后继续(删除第一个匹配事件并继续第二个事件) after last -在最后一个元素之后继续(有效地丢弃匹配序列的所有元素)
例如,如果我们有一系列事件: A , B , C 和图案 first -> second 我们将得到下一个结果: from first - A -> B , A -> C ,
B -> C after first - A -> B ,
B -> C after last - A -> B 现在,问题以一条注解结束,所有这些注解都在其他任务中实现:
其他问题包括量词实现、跳到下一个以及循环模式中连续性的一些附加问题。
那么,有人能告诉我如何使用flink cep库的当前api实现已定义的行为吗?

whhtz7ly

whhtz7ly1#

我已经找到了问题的答案,我想和大家分享这个信息:在找到匹配序列后,匹配算法应该如何继续的行为可以由 AfterMatchSkipStrategy . 但是,它只在1.4版之后才起作用。好吧,我们在等释放。
更多信息:https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html#after-匹配跳过策略。

相关问题