当前位置: 首页 > 知识库问答 >
问题:

Flink CEP中的序列匹配语义学

富念
2023-03-14

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

  • 从第一个开始-继续保留所有事件以备将来匹配(即当前行为)
  • 在第一个之后-在第一个元素之后继续(删除第一个匹配事件并继续第二个事件)
  • 在最后之后-在最后一个元素之后继续(有效地丢弃匹配序列的所有元素

例如,如果我们有一系列事件:< code>A、< code>B、< code>C和模式< code >首先-

    < Li > < code > from first -< code > A-

现在,问题以一条评论结束,所有这些都在其他任务中实现:

这被其他问题所涵盖,包括量词的实现、跳到下一个以及循环模式中的一些其他连续性问题。

那么,有人能告诉我如何使用Flink CEP库的当前API实现定义的行为吗?

共有1个答案

严扬
2023-03-14

我已经找到了我的问题的答案,我想分享这个信息:匹配算法在找到匹配序列后应该如何继续的行为可以由< code > AfterMatchSkipStrategy 定义。但是,它只适用于1.4版本。嗯,我们在等待发布。

以下是更多信息:https://ci . Apache . org/projects/flink/flink-docs-release-1.4/dev/libs/CEP . html # after-match-skip-strategy。

 类似资料:
  • 我尝试用Java编写regex来匹配URL。我在互联网上找到了regex,它在在线regex编辑器中工作得很好。当我试图在eclipse上运行它时,它会给出以下错误:无效的转义序列(有效的转义序列是\B\T\N\F\R\\“\'\\) 我怎样才能解决这个问题?

  • 最佳实践 保存模型的推荐方法 这主要有两种方法序列化和恢复模型。 第一种(推荐)只保存和加载模型参数: torch.save(the_model.state_dict(), PATH) 然后: the_model = TheModelClass(*args, **kwargs) the_model.load_state_dict(torch.load(PATH)) 第二种保存和加载整个模型:

  • 问题内容: 我在排序查询结果时遇到麻烦。 执行此查询后: 或这个: 我得到的结果是: 我的问题是: 我该怎么做才能获得下一个顺序的结果? 我正在使用posgresql 9.1。 提前致谢。 问题答案: 尝试通过以下方式明确显示顺序:

  • 我希望通过将嵌套的JSON字符串递归地拆分{}来解析它们。我得到的regex是“{([^}]*.?)}”,我已经测试过它可以恰当地获取我想要的字符串。但是,当我试图将它包含在Java中时,我得到了以下错误:“无效的转义序列(有效的转义序列是 这是我的代码,也是错误发生的地方: 我做错了什么?

  • 本文向大家介绍Scala序列上的模式匹配,包括了Scala序列上的模式匹配的使用技巧和注意事项,需要的朋友参考一下 示例 检查集合中元素的准确数量 现场演示 提取first(s) element(s)并将其余部分保留为集合: 通常,可以用于构建序列的任何形式都可以用于与现有序列进行模式匹配。 请注意,在使用Nil和::在对序列进行模式匹配时将起作用,但确实会将其转换为List,并且可能会产生意外结

  • HLOJ 9525,习题3-5 栈序列匹配 题目描述 对于给出的入栈序列和出栈序列,判断这两个序列是否相容,即能否利用栈操作将入栈序列转换为出栈序列。若相容,则输出yes,否则输出no。要求在判断栈序列的匹配过程中,给出入栈、出栈的过程。 输入格式: 首先输入一个整数T,表示测试数据的组数,然后是T组测试数据。每组测试数据输入用一个空格分隔的两个字符串(两个串的长度可能不一样,长度均不超过10),