回答情况：
提问时间：
问题标签：
我是Flink和Flink CEP的新手。使用事件时间时，Flink CEP是否以升序(事件-)时间顺序迭代事件以检查模式？提前感谢！
浏览 33提问于2019-02-28得票数 0
回答已采纳
我是新的Flink CEP，并试图测试基本的东西-在下面的代码，我的期望是所有的输入应该匹配模式，并应打印为匹配的结果。package com.o9.flink;import org.apache.flink.cep.CEP;import org.apache.flink.cep.functions.PatternProcessFu
浏览 9提问于2022-08-09得票数 0
回答已采纳
有没有办法以可共享的格式(例如Json)指定Apache Flink CEP模式？
我的用例是:开发一个规则引擎，允许用户在不编写大量Java代码的情况下定制CEP模式，并轻松地与其他人共享模式。
浏览 2修改于2021-07-30得票数 0
Flink CEP如何管理间歇性状态？它将它们存储在哪里？它只是在内存中，还是有一个快速的持久存储来支持这些状态？
文档没有在任何地方提到这一点。
浏览 13提问于2017-12-16得票数 3
回答已采纳
flink运行/home/admin/Documents/flink_cep/Flink-master/dist/Kinesis.jar
当我试图在命令行中运行Jar文件时，会出现错误，但我的代码在
浏览 0修改于2021-07-30得票数 0
回答已采纳
我正在和Flink CEP贪婪的运算符进行一场战斗。return value.equals("6"); });
return "-"; });
env.execute(&qu
浏览 2提问于2017-12-30得票数 0
我已经在Flink中实现了CEP模式，它正在按预期工作，连接到本地Kafka broker。但是当我连接到基于集群的云kafka设置时，Flink CEP并没有触发。1594017873133
我已经附加了Flink
浏览 2修改于2020-07-07得票数 0
回答已采纳
我在Flink SQL中使用CEP模式，它正在按预期工作，连接到Kafka broker。但是当我连接到基于集群的云kafka设置时，Flink CEP并没有触发。inbound","application_id":"app1","connect_time":1635206501735,"row_time":"2021-10-25 16:07:09.019Z"}
在flink我运行cep<
浏览 1修改于2021-10-26得票数 0
回答已采纳
我结合了两个主题数据，并在其之上创建了一个视图，并试图使用flink cep sql来获取输出，但不知何故无法弄清楚。
浏览 6修改于2022-10-06得票数 1
我开始研究用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
回答已采纳
我用Flink实现了一个模式，它匹配三个事件，比如A->B->C。在定义了我的模式之后，我生成一个有了这样一个PatternSelectFunction我知道传统的Flink流API提供了丰富的功能，允许您注册Flink的内部延迟跟踪器，如本所述。我还看到Flink 1.8增加了一个新的RichPatternSelectFunction。
浏览 0提问于2019-01-21得票数 1
回答已采纳
使用Flink CEP时，Context具有currentProcessingTime属性。使用System.currentTimeMillis()和这种方法有区别吗？import org.apache.flink.api.scala._
ctx.currentProcessingTime == Syst
浏览 77提问于2019-12-29得票数 0
} .within(Time.milliseconds(WindowLength_join__ms)); at org.apache.flink.cep.operator.KeyedCEPPatternOperator.emitMatchedSequences(KeyedCEPPatternOperator.java:77
浏览 0提问于2018-01-04得票数 0
我认为只有使用flink cep才能做到这一点。但是flink-sql-cep不支持聚合。它只计算已发生事件。在这种情况下，如何使用单个SQL完成此任务。我试了两个步骤，我先用flink sql cep来匹配，然后再沉到kafka。在步骤中，我使用前kafka和使用窗口聚合。
浏览 0提问于2019-10-12得票数 0
我有一个本地设置，其中Flink处理由Debezium生成的JSON事件。这样做的目的是监视客户支持代理和客户之间的对话。如果客户支持代理没有在特定的时间范围内回复消息，我想发出警告。我的Flink CEP代码如下所示： WatermarkStrategy<MessageEvent> watermarkStrategy;
KafkaSou
浏览 9提问于2022-10-08得票数 0
回答已采纳
我是新来的Flink CEP。对于我们的一个用例，我们需要为温度传感器输出实现流分析。如果温度持续升高30分钟，需要向操作员发出警报。我浏览了模式API，但无法找到在模式中对此建模的方法？
浏览 2提问于2020-02-15得票数 0
回答已采纳
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我们回到了普通的Flink。因此，我希望就这些问题作出一些说明：
如果Flink看起来更完整，为什么要创建CEP库？使用CEP</em
浏览 6提问于2020-03-05得票数 0
回答已采纳
我想要检测具有相同属性的事件。假设我有一个简单的case类：假设有以下流：Record("B", 2)Record("C", 4)val start: Pattern[Record, _] = myStream.followedBy("second&#
浏览 1提问于2016-08-04得票数 1
我正在尝试在无序流事件的FLINK上实现CEP模式。.withTimestampAssigner((event, timestamp) -> event.getGeneratedDate().toEpochSecond())) 我的模式通过以下代码链接到我的流：
SingleOutputStreamOperator<DataOutput> enterStream = CEP</em
浏览 11提问于2022-01-28得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号