java - Flink CEP 中的序列匹配语义

Question

Apache JIRA 中有一个问题：https ://issues.apache.org/jira/browse/FLINK-3703 。它允许在找到匹配序列后定义匹配算法应该在哪里继续，并且存在三种类型的行为：

• from first- 继续为未来的比赛保留所有事件（即当前行为）
• after first- 在第一个元素之后继续（删除第一个匹配事件并继续第二个事件）
• after last- 在最后一个元素之后继续（有效地丢弃匹配序列的所有元素）

例如，如果我们有一系列事件：A、、和模式B，我们将得到下一个结果：Cfirst -> second

• from first- A -> B, A -> C,B -> C
• after first- A -> B,B -> C
• after last-A -> B

现在问题已结束，并附有一条评论，所有这些都在其他任务中实现：

这被其他问题所涵盖，包括 Quantifier 实现、skip-till-next 以及循环模式内连续性的一些其他问题。

那么，有人能告诉我如何使用 Flink CEP 库的当前 API 来实现定义类型的行为吗？

Answer 1

我找到了我的问题的答案，我想分享这个信息：在找到匹配序列后匹配算法应该如何继续的行为可以定义为AfterMatchSkipStrategy。但是，它仅适用于 1.4 版。好吧，我们正在等待发布。

这里有更多信息：https ://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html#after-match-skip-strategy 。