1回答
如果pattern定义只有属性级比较，Flink-CEP是否使用hashCode()和equals()进行比较？
我这么问是因为我不能保证hashCode()的正确性。
浏览 3提问于2016-12-14得票数 1
我需要使用Flink-CEP将每个模式应用于事件流。当我事先不知道模式时，有没有办法从DataStream中获取PatternStream？
浏览 9提问于2017-12-19得票数 0
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析重载方法”，它指的是pattern方法。根据我用来分别创建输入和模式的readTextFile和Pattern[String].begin('line').where(_.length == 10)的实现，方法的参数或泛型类
浏览 50提问于2020-01-14得票数 0
回答已采纳
我试图使用FLINK-CEP来衡量一个市场上从BidState.OPEN到BidState.Closed的投标时间。
浏览 0提问于2019-05-28得票数 0
回答已采纳
有人能帮我解决以下错误吗？我认为版本有一些问题，但我不知道如何修复它。我试图运行Apache，我使用Kafka主题作为输入，在尝试运行Flink时，我得到了以下错误：
线程"main“中的异常:org/apache/flink/util/ org.apache.flink.cep.pattern.Pattern.where(Pattern.java:130) at hes.cs63.CEPMonitor.CEPMonitoring.main(CEPMonitoring.java:55)，由: java.lang.ClassNotFoundException: org.apac
浏览 3提问于2017-11-20得票数 1
打开盒子，它看起来不像EMR的Flink发行版包括可选的jars (flink-指标-prometheus，flink-cep等等)。我知道Flink还有其他可选的库，如果您想要使用flink-cep，通常需要复制它们，但是我不知道如何在使用EMR时做到这一点。
这是我得到的例外，我认为这是因为它无法在其类路径中找到度量jar。
浏览 0提问于2019-03-06得票数 4
回答已采纳
1回答
我在Apache Flink的BroadcastStream中有一组规则。当新规则应用到我的事件流中时，我能够应用新规则。但是，如果我的规则像这样，我不知道该如何实现rule 2> alert when count of event a is greater than 4 in a window of 15 mins
浏览 1提问于2019-11-07得票数 0
2回答
更详细地说，我正在使用flink-core、flink-cep和flink-streaming库。
浏览 5提问于2017-07-31得票数 1
回答已采纳
</dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-cep
浏览 9提问于2022-08-09得票数 0
回答已采纳
flink-runtime-web" % flinkVersion % "provided",
"org.apache.flink" %% "flink-cep
浏览 0提问于2020-08-24得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
