我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析重载方法”，它指的是pattern方法。import
浏览 50提问于2020-01-14得票数 0
回答已采纳
我试图运行Apache，我使用Kafka主题作为输入，在尝试运行Flink时，我得到了以下错误：
<dependencies> <groupId>
浏览 3提问于2017-11-20得票数 1
我在仪表板和IntelliJ中都使用Flink 1.3.2。ClassNotFoundException说，当我从源代码构建Flink时，我看到了很多警告消息，这使我相信迭代条件类没有包含在jar中，因为错误也是如此。下面是错误
Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeConditionjava.lang.Class.ge
浏览 1提问于2017-10-28得票数 0
回答已采纳
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;
importorg.apache.flink.<em
浏览 3提问于2017-07-11得票数 1
回答已采纳
我是新的Flink CEP，并试图测试基本的东西-在下面的代码，我的期望是所有的输入应该匹配模式，并应打印为匹配的结果。package com.o9.flink;import org.apache.flink.cep.CEP;import org.apache.flink.cep.functions.PatternProcessFu
浏览 9提问于2022-08-09得票数 0
回答已采纳
1回答
下面是代码片段 ep.event_flink_time, HOP_START (cep.event_flink_time, INTE
浏览 25提问于2022-05-24得票数 0
我正在制作一个Flink CEP应用程序，通过Kafka读取数据。当我试图捕捉模式时，当它之后没有数据时，接收器操作就不会发生。例如，我希望A-> B-> C作为一个模式。卡夫卡提供了A，B，C数据。;import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.tuple.Tup
浏览 1提问于2021-05-21得票数 0
我有下面的Flink程序：env.setStreamTimeCharacteristicgetAsJsonObject()
val patternStream = CEP.pattern
浏览 4提问于2017-07-05得票数 0
回答已采纳
1回答
我是Flink和Flink CEP的新手。使用事件时间时，Flink CEP是否以升序(事件-)时间顺序迭代事件以检查模式？提前感谢！
浏览 33提问于2019-02-28得票数 0
回答已采纳
我正在使用1.3.0的Flink版本。import org.apache.flink.cep.CEP;import org.apache.flink.cep.PatternStream;im
浏览 0提问于2017-08-07得票数 0
回答已采纳
2回答
connectionConfig, // config for the RabbitMQ connection });
PatternStream<String> timedOutPatternStream = CEP.pattern
浏览 0提问于2018-05-15得票数 2
回答已采纳
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我们回到了普通的Flink。因此，我希望就这些问题作出一些说明：
如果Flink看起来更完整，为什么要创建CEP库？使用CEP</em
浏览 6提问于2020-03-05得票数 0
回答已采纳
()Lorg/apache/flink/configuration/ReadableConfig; at com.teavaro.cep.modules.propensityscores.PropensityScoresUseCaseHandler<init>(Prop
浏览 6提问于2022-05-30得票数 0
1回答
我正在尝试打印一个字符串，如果使用Flink CEP库找到Hello和world。我的来源是Kafka，并使用控制台生产者输入数据。这一部分正在发挥作用。我可以打印出我在主题中输入的内容。下面是类import org.apache.flink.cep.PatternStream;
importorg.apache.flink.cep.p
浏览 10提问于2016-09-19得票数 2
com.google.gson.Gson;import com.google.gson.JsonParser;import org.apache.flink.cep.PatternSelectFunction;importorg.apache.<e
浏览 1提问于2017-09-21得票数 0
2回答
我感兴趣的是有什么方法可以实现CEP(复杂事件处理)系统来进行监控。我需要监视许多设备，并且需要使用事件过滤器比较结果。
有没有针对这种特殊情况的现代架构？
浏览 21提问于2016-07-18得票数 0
消费者样本数据{"temperature" : 28,"machineName":"xyz"}
DataStream<Alert> patternStream = CEP.pattern(inputEventStreamKafkaApp.java:53$2.flatSelect(KafkaApp.java:53) at org.apache.flink.cep.operator.FlatSelectCepOperator.processMatchedSequences(
浏览 0提问于2019-02-27得票数 0
</artifactId> <version>1.0</version>
<groupId>org.apache.flink</grou
浏览 1提问于2017-11-09得票数 0
回答已采纳
2回答
我正在尝试运行这个程序: Flink CEP监控
缺少“Map”的泛型类型参数。org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameter(TypeExtractor.java:1316) org.apache.flink.api.java.typeutils.TypeExtractor
浏览 3提问于2016-05-05得票数 2
1回答
有什么方法可以用Flink CEP库创建这个模式吗？input List(1,2,2,2,3,3,2,1,1,1,3,0,1)List(2,2,2,3)List(1,1,1)
我知道有很多方法可以通过Flink本身来完成它，但是我想用CEP来完成它，我认为它需要支持将上下文传递到下一个条件，对吗？如果是这样的话，Flink CEP是否可以传递上下文或修改流中的事件，并将一些额外的数据传递给下一个条件？
浏览 6提问于2022-09-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
