目前，我正在做一个学期的项目，在这个项目中，我必须认识到三个事件的系列。像P -> R -> P一样 我们有两种不同的事件类型，在同一主题中通过Kafka连接器消费。我创建了一个名为Event的父类，其他两个类型从该父类派生而来。 Kafka连接器将带有EventSchema的JSON反序列化为父类事件。，如果我以适当的格式发送三条消息，该模式将无法识别。我尝试过<em
浏览 22提问于2019-01-17得票数 0
回答已采纳
我必须收集三个事件在三个卡夫卡来源的流具有相同的correlationId在给定的时间，并能够收集所有或部分这些事件，如果他们到达晚。
我在3 DataStream和CEP模式上使用了一个联合。但是我注意到，与模式很好地匹配并因此在select函数中收集的事件一旦到达，也会在超时函数中发送。我不知道我在我的例子中做错了什么，也不知道我不明白什么，但我期望那些与之匹配的事件<
浏览 0提问于2017-08-07得票数 0
回答已采纳
2回答
connectionConfig, // config for the RabbitMQ connection });
PatternStream<String> timedOutPatternStream = CEP.pattern
浏览 0提问于2018-05-15得票数 2
回答已采纳
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep</
浏览 3提问于2017-07-11得票数 1
回答已采纳
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev根据我用来分别创建输入和模式的readTextFile和Pattern[String].begin('line').where(_.leng
浏览 50提问于2020-01-14得票数 0
回答已采纳
我写了这样一个简单的模式Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeConditionjava.lang.Class
浏览 1提问于2017-10-28得票数 0
回答已采纳
1回答
我是Flink和Flink CEP的新手。使用事件时间时，Flink CEP是否以升序(事件-)时间顺序迭代事件以检查模式？提前感谢！
浏览 33提问于2019-02-28得票数 0
回答已采纳
1回答
我们使用Apache beam通过Flink处理来自不同来源的事件。在这种情况下，我们需要使用Flink的CEP引擎来定义事件模式并发出警报。我在beam中找不到任何用于此的包装器API。
浏览 22提问于2019-12-06得票数 1
回答已采纳
我是新的Flink CEP，并试图测试基本的东西-在下面的代码，我的期望是所有的输入应该匹配模式，并应打印为匹配的结果。package com.o9.flink;import org.apache.flink.cep.CEP;
importjava.util.ArrayList;
浏览 9提问于2022-08-09得票数 0
回答已采纳
我试图运行Apache，我使用Kafka主题作为输入，在尝试运行Flink时，我得到了以下错误：
线程"main“中的异常:org/apache/flink/util/ org.apache.flink.cep.pattern.Pattern.wherehes.cs63.CEPMonitor.CEPMonitoring.main(CEPMonitoring.java:55)，由: java.l
浏览 3提问于2017-11-20得票数 1
2回答
我正在尝试运行这个程序: Flink CEP监控
缺少“Map”的泛型类型参数。您的编译器似乎没有将它们存储到.class文件中。目前，只有Eclipse编译器保存使用lambdas特性类型所需的类型信息--安全。有关如何编译包含lambda表达式的作业的详细信息
浏览 3提问于2016-05-05得票数 2
2回答
我感兴趣的是有什么方法可以实现CEP(复杂事件处理)系统来进行监控。我需要监视许多设备，并且需要使用事件过滤器比较结果。
有没有针对这种特殊情况的现代架构？
浏览 21提问于2016-07-18得票数 0
我用Flink实现了一个模式，它匹配三个事件，比如A->B->C。在定义了我的模式之后，我生成一个有了这样一个PatternSelectFunctionpatternStream.select(new MyPatternSelectFunction()).print();
这就像一种魅力，但我对所有匹配事件</e
浏览 0提问于2019-01-21得票数 1
回答已采纳
我正在制作一个Flink CEP应用程序，通过Kafka读取数据。当我试图捕捉模式时，当它之后没有数据时，接收器操作就不会发生。例如，我希望A-> B-> C作为一个模式。卡夫卡提供了A，B，C数据。我在等DS::2> {"ActionID":"2.24"}那么，为什么在满足条件之后，而不是在满足
浏览 1提问于2021-05-21得票数 0
1回答
我有一个简单的模式，如下所示我在执行过程中遇到以下错误，但问题是该错误是在程序运行一段时间后出现的(KeyedCEPPatternOperator.ja
浏览 0提问于2018-01-04得票数 0
我正在尝试建立一个与Apache Flink相关事件的CEP系统。其中一个需求是能够在运行时添加新的异常检测模式，而不会丢失系统可用性。你知道我该怎么做吗？例如，如果我有一个安全事件流(例如访问、身份验证)和一个用于检测异常的模式(例如，在1分钟内超过10次登录到同一台计算机)，我希望能够更改模式参数，例如，代替10次登录，也许我希望能够同时创建其他模式(保持相同的</em
浏览 0提问于2016-10-10得票数 3
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我
浏览 6提问于2020-03-05得票数 0
回答已采纳
我有下面的Flink程序：env.setStreamTimeCharacteristicgetAsJsonObject()
val patternStream = CEP.pattern我的dataStream由JSON对象组成，我在JS
浏览 4提问于2017-07-05得票数 0
回答已采纳
我试图发送一个警报，每次发生的事件具有相同的ID。为此，我使用keyBy()应用我的操作根据ID。org.apache.flink.api.scala._import org.apache.flink.cep.pattern.Patternimport org.apache.<em
浏览 3提问于2020-03-02得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
