我对Apache Flink流API有一个问题。@RequiredArgsConstructor
public class EventDataConsumer extends RichSinkFunction<EventData，将一个方法引用传递给这个SinkF
浏览 4提问于2017-08-24得票数 0
回答已采纳
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。例如，Flink只显示事件匹配跳过的。虽然这些语义对于很多情况来说都是足够的，但它可能不能解决具体的问题，这使我们回到了普通的<e
浏览 6提问于2020-03-05得票数 0
回答已采纳
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
从Flink 1.5发布公告中，我们知道Flink现在支持“广播状态”，并描述了“广播状态为Flink的CEP库的”动态模式“特性的实现打开了障碍。”这是否意味着目前我们可以使用“广播状态”来实现“动态模式”而不需要Flink CEP？另外，我不知道在有或没有广播状态的情况下实现Flink CEP的“动态模式”有什么区别？如果有人能给出一个用代码解释区别的例子，我
浏览 1提问于2018-05-26得票数 0
回答已采纳
我刚从Flink CEP开始，我来自Esper CEP引擎。例如，使用下面的模式，您可以创建一个5秒的批处理窗口，并计算在该指定窗口中接收到的所有Stock事件的属性Stock的平均值。select avg(price) from Stock#time_batch(5 sec)
问题是，我想知道如何在Flink CEP上实现这一点。我知道，Flink CEP中的目
浏览 0提问于2018-10-05得票数 0
回答已采纳
我在测试新的Flink 1.0.0功能时遇到了一些麻烦。我一直在修改CEP，但我还没有成功运行一个简单的演示代码：
val pattern : Pattern[TrafficEvent, _] = Pattern.begin[TrafficEvent]("startTrafficEvent是一个只有很少简单字段的类，而流是该类的Scala DataStream。在Flink上运行代码时会显示错误。org.apache.<em
浏览 0提问于2016-04-06得票数 2
回答已采纳
1回答
Flink和动态模板识别
、、、
我们计划使用Flink CEP根据一些动态模板处理大量事件。系统必须识别事件链(有时是带有条件和分组的复杂链)。模板将由用户创建。换句话说，我们必须在不接触代码的情况下创建复杂的模板。是否可以使用Apache Flink来解决此问题？Filnk支持动态模板吗？
浏览 3提问于2016-10-13得票数 1
我能够成功地运行我的flink作业，它使用S3保存到./bin/flink run ...。为此，我必须将flink- S3 -fs-presto jar复制到我的$FLINK_HOME/lib文件夹中，还必须在我的flink-conf.yaml中配置我的S3连接详细信息。您需要在flink的flink- both .但是，当我试图从IDE (Inte
浏览 2提问于2018-01-26得票数 1
我正在尝试在无序流事件的FLINK上实现CEP模式。.withTimestampAssigner((event, timestamp) -> event.getGeneratedDate().toEpochSecond())) 我对forBoundedOutOfOrderness的理解是，如果一个元素在11:01:00使用generatedDate字段= 10:0
浏览 11提问于2022-01-28得票数 0
1回答
我正在编写一个简单的示例，用于在Flink中使用最新的Github 1.1-SNAPSHOT版本测试新的Scala API for CEP。._3 < 4)
def selectFn(pattern : mutable.Map此外，当尝试添加阶段时，代码无法编译。如果我将模式更改为(查找第3个字段小于4的两个连续
浏览 2提问于2016-05-25得票数 1
我正在尝试实现一个类，使用户能够操纵N个输入流，而不对输入流的类型有限制。我想知道的是：非常感谢。at org.apache.flink.api.java.Clos
浏览 19提问于2020-04-09得票数 2
回答已采纳
我们使用flink-cep作为一个独立的库来查找事件列表中的模式。mapOf(patientKey to 3, hr to 2))我们想要编写一个以匹配的形式返回的模式：第二场比赛: p2e1，p2e2，p2e3因此，在有键流的flink<
浏览 9提问于2022-10-17得票数 0
我们需要一个可以在大型数据集上运行的CEP引擎，所以我看了一下FLink，Ignite等替代引擎。Thx
浏览 0提问于2016-07-29得票数 0
我希望通过Flink、Scala-language和addSource- and readCsvFile-函数来读取csv文件。我还没有找到任何关于这方面的简单例子。我只发现：和这个对于我的目的来说太复杂了。在阅读之后，我想使用CEP (复杂事件处理)。
浏览 0提问于2018-02-16得票数 1
1回答
Flink码头组合自定义库
、、、、
我正在尝试设置一个Flink会话集群使用坞-撰写。我希望在Flink中加载一个自定义库，因为这个库包含我所有作业使用的代码。我这样做的方法是创建一个自定义的码头映像，如下所示：WORKDIR /opt/flink/lib
RUN“的字段<
浏览 6提问于2020-11-11得票数 0
我现在已经设置了Flink，并在EMR上运行了一个作业，现在我正试图通过将指标发送到prometheus来添加监视。
“要使用此记者，必须将/opt/flink
浏览 0提问于2019-03-06得票数 4
回答已采纳
我使用Flink SQL和CEP来识别一些非常简单的模式。然而，我发现了一个奇怪的东西(很可能是个bug)。下面有两个示例表password_change和transfer。的查询结果。eventtype='transfer' 它应该输出456,transfer,2020-01-01T01:00:04Z
但是在运行Flink另一方面，如果我从两个表中提取这些列并手动将它们合并到一个表中
浏览 0提问于2020-10-09得票数 0
回答已采纳
我们的Flink工作遇到了一个很难观察的问题.这份工作相当简单，它：
我们运行的是Flink</em
浏览 14提问于2020-10-01得票数 0
1回答
我想在flink流处理作业中将对象序列化为Json。在flink作业中，所有对象都需要可序列化。
我用杰克逊来序列化我的对象。
浏览 8提问于2016-12-08得票数 0
回答已采纳
所以，我有一个检查.blur触发的CEP (邮政编码)的函数，当从控制台触发时，它工作得很好，但当通过外部.js导入时，它就不会运行了。if (cep !loadSequence($("#pid").val())); }); }编辑:嗯.原因似乎是#i11字段是在页面中动态加载的，所以我已经将问题更新为更合适的问题。编辑2:根据上<
浏览 0提问于2016-06-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
