回答情况：
提问时间：
问题标签：
我使用Flink和FlinkCEP来检测数据流上的复杂事件。出于研究目的，我只需要测量识别时间。 我正在使用Flink / FlinkCEP - 1.7.1。在此之后，我将使用FlinkCEP：CEP.pattern(....)以及其他select和print函数。
浏览 26提问于2019-09-04得票数 1
我仍然是Flink CEP库的新手，但我还不了解模式检测行为。考虑到下面的例子，我有一个Flink应用程序，它消耗来自kafka主题的数据，数据是定期产生的，我想使用Flink CEP模式来检测一个值何时大于给定的阈值。代码如下： public class CEPJob{ public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
浏览 27提问于2021-04-21得票数 0
回答已采纳
像siddhi，FlinkCEP和Esper这样的复杂事件流处理引擎是做什么的。我在网上浏览了一下，没有得到任何关于这方面的信息。请让我理解在CEP和规则引擎中使用的模式匹配。
浏览 9提问于2018-01-25得票数 1
1回答
我尝试过FlinkCEP，它以某种方式完成了工作，但它似乎不适合复杂的事件模式，或者很难学习如何使用它。复杂事件模式的例子很少。BR Esa
浏览 12提问于2018-08-16得票数 0
我想使用FlinkCEP只在模式上进行“懒惰”匹配。我该怎么做？例如，我有一个输入流ACABCABCB，我希望在一个followedBy C上匹配，只得到3个匹配，而不是6个匹配。
浏览 1修改于2016-07-07得票数 1
/Desktop/flinkcepout",FileSystem.WriteMode.OVERWRITE)
env.execute() 下面是我的build.sbt文件内容： name := "FlinkCEP
浏览 50提问于2020-01-14得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号