但是我注意到，与模式很好地匹配并因此在select函数中收集的事件一旦到达，也会在超时函数中发送。我不知道我在我的例子中做错了什么，也不知道我不明白什么，但我期望那些与之匹配的事件也不会处于超时状态。我正在使用1.3.0的Flink版本。import org.apache.flink.
浏览 0提问于2017-08-07得票数 0
回答已采纳
2回答
connectionConfig, // config for the RabbitMQ connection });
PatternStream<String> timedOutPatternStream = CEP.pattern
浏览 0提问于2018-05-15得票数 2
回答已采纳
在engine事件模式中，有Every操作符，它指示当每个关键字限定的子表达式计算为true或false时，模式子表达式应该重新启动。，我们可以以不同的方式使用every操作符，例如： every ( A -> B ) A -> every B我想知道在Flink CEP中哪些模式是可能的？我想在F
浏览 0提问于2017-01-09得票数 0
回答已采纳
我有一个用例，其中大量的日志将被消耗到apache。我的用例是查找蛮力攻击和端口扫描攻击。这里的挑战是，在普通CEP中，我们将值与常量(如"event“= login )进行比较。在这种情况下，标准是不同的，就像在蛮力攻击的情况下，我们有如下的标准。
对于端口扫描，我们
浏览 4提问于2020-09-29得票数 0
2回答
我正在和Flink CEP贪婪的运算符进行一场战斗。return value.equals("6"); });
return "-"; });
env.ex
浏览 2提问于2017-12-30得票数 0
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;
importor
浏览 3提问于2017-07-11得票数 1
回答已采纳
1回答
我有一个简单的模式，如下所示我在执行过程中遇到以下错误，但问题是该错误是在程序运行一段时间后出现的(SocketClientSink.java:146)
我想我之所以选择这个模式，是因为我在模式中<
浏览 0提问于2018-01-04得票数 0
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我们回到了普通的<e
浏览 6提问于2020-03-05得票数 0
回答已采纳
2回答
我正在尝试运行这个程序: Flink CEP监控
缺少“Map”的泛型类型参数。您的编译器似乎没有将它们存储到.class文件中。目前，只有Eclipse编译器保存使用lambdas特性类型所需的类型信息--安全。有关如何编译包含lambda表达式的作业的详细信息，请参阅文档。) org.apach
浏览 3提问于2016-05-05得票数 2
2回答
我感兴趣的是有什么方法可以实现CEP(复杂事件处理)系统来进行监控。我需要监视许多设备，并且需要使用事件过滤器比较结果。
有没有针对这种特殊情况的现代架构？
浏览 21提问于2016-07-18得票数 0
我们使用flink-cep作为一个独立的库来查找事件列表中的模式。mapOf(patientKey to 3, hr to 2))我们想要编写一个以匹配的形式返回的模式：第二场比赛: p2e1，p2e2，p2e3因此，在有键流的<
浏览 9提问于2022-10-17得票数 0
我是Flink CEP的新手，为了更好地理解它们，我一直在玩弄这些模式。我有一个简单的"begin“和”followedBy“的例子，我注意到在followedBy的例子中，同一个事件循环了很多次，这里我漏掉了什么？StreamExecutionEnvironment环境= StreamExecutionEnvironment.getExecutionEnvironment().setPa
浏览 88提问于2020-08-28得票数 0
但是，为了使我添加到patternProcess函数中的接收器操作工作，来自kafka的数据必须类似于A、B、C、X。如何解决这个问题请帮助。编辑import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.
浏览 1提问于2021-05-21得票数 0
2回答
下面显示了在Flink-CEP中检测模式的代码 at org.apache.flin
浏览 0提问于2017-08-13得票数 3
回答已采纳
我在测试新的Flink 1.0.0功能时遇到了一些麻烦。TrafficEvent是一个只有很少简单字段的类，而流是该类的Scala DataStream。在Flink上运行代码时会显示错误。org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:302)它在PatternStream.select行中抛出了相同
浏览 0提问于2016-04-06得票数 2
回答已采纳
import org.apache.flink.cep.scala.pattern.Patternimport org.apache.flink.streaming.api.TimeCharacteristicimport org.apache.flink.streaming.api.scala._
import org.apache.flink</
浏览 1提问于2017-07-07得票数 1
回答已采纳
在Apache Flink中获取Exception in thread "main" java.lang.IndexOutOfBoundsException。我试着在效仿，但我得到了免责的提法。下面是我的主类的一个片段。我将感谢任何关于我做错了什么或如何排除错误的指针。alertPattern);Exception in thread "main" java.lang.IndexOutOfBoundsExc
浏览 1提问于2017-11-24得票数 0
我有一个场景，如果第二个事件在x秒内没有跟随第一个事件，则必须更改状态。例如，如果用户在100分钟内没有注销，则认为他处于无效状态。如何使用当前的模式操作来设计？
浏览 0提问于2016-04-12得票数 5
回答已采纳
1回答
我想检测所有相同整数的序列，后面跟着这些整数的计数。有什么方法可以用Flink CEP库创建这个模式吗？假设如下：这些序列应该被检测到：List(3,3,2)我知道有很多方法可以通过Flink本身来完成它，但是我想用CEP来完成它，我认为它需要支持将上下文传递到下一个条件，对吗？如果是这样的话，
浏览 6提问于2022-09-10得票数 0
回答已采纳
这一次我的问题是:使用MapState，使用mapstate.put(key, value)将键的当前值修改到mapState中是安全的，或者我需要执行mapState.remove(key)，然后再次执行从Flink的状态抽象开始，抽象不是为并发访问而设计的，也不应该在多个线程之间共享。那么，重新表述我的问题:我可以根据键将值更新到mapState中，而不需要删除键然后再放入键吗？因为我有一个例外： java.util.Concur
浏览 43提问于2020-04-16得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
