使用Flink CEP时，Context具有currentProcessingTime属性。使用System.currentTimeMillis()和这种方法有区别吗？这里有一个小实验，看起来这些值几乎是相等的(至少在这个简单的场景中是这样)。import org.apache.flink.api.scala._
valIterativeCondition.Con
浏览 77提问于2019-12-29得票数 0
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析
浏览 50提问于2020-01-14得票数 0
回答已采纳
我写了这样一个简单的模式Caused by: java.lang.NoClassDefFoundError: org/apache/flink/<
浏览 1提问于2017-10-28得票数 0
回答已采纳
我试图运行Apache，我使用Kafka主题作为输入，在尝试运行Flink时，我得到了以下错误：
<dependencies>
浏览 3提问于2017-11-20得票数 1
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;
importorg.apache.
浏览 3提问于2017-07-11得票数 1
回答已采纳
我是新的Flink CEP，并试图测试基本的东西-在下面的代码，我的期望是所有的输入应该匹配模式，并应打印为匹配的结果。package com.o9.flink;import org.apache.flink.cep.CEP;import org.apache.flink.<em
浏览 9提问于2022-08-09得票数 0
回答已采纳
1回答
我有两个来自两个Kafka主题的流表，我想加入这些流并对所连接的数据执行聚合功能。需要使用滑动窗口连接流。TIMESTAMPDIFF(SECOND, ep.event_flink_time, cep.event_flink_time) as timediff,group by HOP(cep.event_flink</e
浏览 25提问于2022-05-24得票数 0
我正在制作一个Flink CEP应用程序，通过Kafka读取数据。当我试图捕捉模式时，当它之后没有数据时，接收器操作就不会发生。例如，我希望A-> B-> C作为一个模式。卡夫卡提供了A，B，C数据。但是，为了使我添加到patternProcess函数中的接收器操作工作，来自kafka的数据必须类似于A、B、C、X。如何解决这个问题请帮助。我在等DS::2> {"ActionI
浏览 1提问于2021-05-21得票数 0
我必须收集三个事件在三个卡夫卡来源的流具有相同的correlationId在给定的时间，并能够收集所有或部分这些事件，如果他们到达晚。我的印象是，不相交<em
浏览 0提问于2017-08-07得票数 0
回答已采纳
我有下面的Flink程序：env.setStreamTimeCharacteristicgetAsJsonObject()
val patternStream = CEP.pattern我的dataStream由JSON对象组成，我在JS
浏览 4提问于2017-07-05得票数 0
回答已采纳
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我们回到了普通的<e
浏览 6提问于2020-03-05得票数 0
回答已采纳
1回答
我是Flink和Flink CEP的新手。使用事件时间时，Flink CEP是否以升序(事件-)时间顺序迭代事件以检查模式？提前感谢！
浏览 33提问于2019-02-28得票数 0
回答已采纳
2回答
connectionConfig, // config for the RabbitMQ connection });
PatternStream<String> timedOutPatternStream = CEP.pattern
浏览 0提问于2018-05-15得票数 2
回答已采纳
这就是我尝试初始化StreamTableEnvironment时遇到的错误 at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create<init>(
浏览 6提问于2022-05-30得票数 0
2回答
我感兴趣的是有什么方法可以实现CEP(复杂事件处理)系统来进行监控。我需要监视许多设备，并且需要使用事件过滤器比较结果。
有没有针对这种特殊情况的现代架构？
浏览 21提问于2016-07-18得票数 0
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
回答已采纳
2回答
我正在尝试运行这个程序: Flink CEP监控
缺少“Map”的泛型类型参数。您的编译器似乎没有将它们存储到.class文件中。目前，只有Eclipse编译器保存使用lambdas特性类型所需的类型信息--安全。有关如何编译包含lambda表达式的作业的详细信息，请参阅文档。) org.apach
浏览 3提问于2016-05-05得票数 2
1回答
我正在尝试打印一个字符串，如果使用Flink CEP库找到Hello和world。我的来源是Kafka，并使用控制台生产者输入数据。这一部分正在发挥作用。我可以打印出我在主题中输入的内容。但是，它不会打印出我的最后一条消息“世界真好！”。它甚至不会打印出它进入了lambda。下面是类import org.apache.flink.<em
浏览 10提问于2016-09-19得票数 2
我有一个条件列表(来自json的获取规则).Data(Json)来自kafka服务器。我想用这个列表过滤数据。但它不起作用。我该怎么做呢？对于keyedstream和警报，我不是很确定。com.google.gson.Gson;import com.google.gson.JsonParser;import org.apache.flink.cep.P
浏览 1提问于2017-09-21得票数 0
我遵循了，并用kafka json实现了相同的样本数据。machine name:" + ((MonitoringEvent) event.get("first")).getMachineName());
现在我遇到了ArrayList cast的问题KafkaApp.java:53$2.flatSelect(KafkaApp.java:53) at org.apache.flink.cep.operator.FlatSelectCepOperator.processMa
浏览 0提问于2019-02-27得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号