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