问题1：我正在研究一个案例场景，我们需要融合来自多个传感器的数据，例如8个传感器，并以树的形式将它们连接起来。例如，加入s1、s2、s3 s4来形成流A，然后加入s5、s6、s7和s8来形成B流，然后在流A和B上执行CEP。
问题2 :可以在多个流上执行CEP吗？中清楚地提到，模式将应用于一个
浏览 4提问于2017-10-29得票数 2
回答已采纳
我试着理解如何在Flink工程中CEP。例如，来自pages：和。我认为基本部分可以是: 1.模式定义2.模式流定义(或者可以使用许多并行流吗?) 3.选择定义是正确的吗？如何使用"se
浏览 0提问于2018-03-06得票数 0
1回答
我正在尝试了解在提交Flink作业之前需要考虑的重要功能有哪些。
我的问题是并行的数量是多少，(物理上)有上限吗？并行性如何影响我的工作表现？例如，我有一个从无键数据流中检测模式的CEP Flink作业，除非我使用KeyBy操作符对数据流进行分区，否则并行度的</em
浏览 0提问于2020-05-15得票数 0
有一台机器正在向CEP engine正在接收的Kafka发送事件流，当流数据上的条件得到满足时，会生成警告。机器将发送大量数据到卡夫卡，有35个来自机器的唯一事件名称(如name1，name2 .name35)，我想要检测每个事件名称组合的模式(比如name1与name2同现，name1与name3同现)。return false; }).within(Time.seco
浏览 29提问于2019-05-16得票数 2
从Flink 1.5发布公告中，我们知道Flink现在支持“广播状态”，并描述了“广播状态为Flink的CEP库的”动态模式“特性的实现打开了障碍。”这是否意味着目前我们可以使用“广播状态”来实现“动态模式”而不需要Flink CEP？另外，我不知道在有或没有广播状态的情况下实现Flink CEP的“动态<em
浏览 1提问于2018-05-26得票数 0
回答已采纳
我想将流SQL放在Kafka中，以供Flink for CEP使用。这是一种好方法吗？有一个供用户定义其设备规则的UI。想象一下，有一个事物跟踪服务(如亚马逊网络服务中心)保持物理设备的状态，我也认为这是将每个设备的</
浏览 7提问于2017-07-20得票数 1
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
浏览 6提问于2022-09-10得票数 0
回答已采纳
<MyObject>begin("start");
..。定义我的模式
DataStream<MyObject> resultStream = patternStream.select(new MyCustomPatternSelectFunction());，我得到了一个结果流，它遵循我设置的
浏览 1提问于2016-12-02得票数 3
回答已采纳
1回答
流在Hadoop中的应用
、、、、
我正在尝试学习的例子。在这个例子中，我确实看到他们创建了一个单独的应用程序(类似于流应用程序)，该应用程序生成和消费数据，并在数据上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个流层，单应用程序就足以满足这一目的，这使得它非常优化。现在，我知道，如果我使用Kafka，那么我需要两个应用程序；一个用于将数据摄取到Kafka主题中，
浏览 2提问于2016-06-13得票数 0
1回答
我对在Flink中可以并行工作的任务的数量感到困惑，在分布式系统中的并行性是多少？以及它与Flink中的computation?Is术语的关系，它是否与我们所说的2并行=2任务并行工作相同? Flink中的，如果两个操
浏览 4提问于2020-04-10得票数 2
假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用Flink对数据进行复杂的事件处理。
Flink 1.3.x中的哪种方法是正确的方法？我看到了不同的方法，如Union、Connect、Window Join。基本上，我只想尝试这样一个简单的CEP：
浏览 3提问于2017-07-12得票数 3
回答已采纳
在过去几天学习Flink CEP库时，我的印象是它没有为Flink的标准功能添加任何新的基本功能。似乎Flink CEP的唯一目的是使事件处理更容易，具有清晰的语义和直观的代码结构。：因此
浏览 6提问于2020-03-05得票数 0
回答已采纳
1回答
我有两个来自两个Kafka主题的流表，我想加入这些流并对所连接的数据执行聚合功能。需要使用滑动窗口连接流。在连接和窗口数据时，我将得到一个错误Rowtime attributes must not be in the input rows of a regular join.TIMESTAMPDIFF(SECOND, ep.event_flink_time, cep.event_flink<
浏览 25提问于2022-05-24得票数 0
1回答
我有下面的情况有2个虚拟机正在发送流到Kafka，CEP引擎正在接收该虚拟机，当满足单个流的特定条件时会生成警告。目前，CEP正在检查两组患者的相同情况(心率> 65，呼吸频率> 68)，并并行提高警报器，如下所示 Pattern<joinEvent, ?joinEvent.getRespirationRate() > 68;
浏览 1提问于2017-08-30得票数 1
回答已采纳
在处理每个数据流的多个数据流和多个操作符时，我试图理解Flink的运行时方面。用例:单个flink作业中的n个数据流(每个数据流代表一个设备--具有不同的时间延迟)，每个数据流被分成两个流</em
浏览 2提问于2017-11-09得票数 1
我是Apache Flink的新手，我正在尝试使用flink CEP对流中的模式进行动态评估。我正在尝试查找执行以下操作的用户: login，addtocart和logout，它能够检测到模式，但如果我定义了多个模式，比如login，logout，它无法检测到模式Action类}
}).print(
浏览 0提问于2020-03-09得票数 1
Apache与Hadoop上的Mapreduce相比如何？在哪些方面更好，为什么呢？
浏览 9提问于2015-04-28得票数 14
回答已采纳
我试图在Android应用程序中运行Apache Flink。我只想运行一个最小的工作示例，如下所示：protected void onCreate(Bundle savedInstanceState) { jcenter()}
delete rootProject.buildDir第一个问题是然而，这会导致更多<
浏览 0提问于2021-03-02得票数 0
我有一个事件数据流和另一个模式数据流。这些模式是由用户在运行时提供的，它们需要通过Kafka主题来提供。我需要使用Flink-CEP将每个模式应用于事件流。当我事先不知道模式时，有没有办法从DataStream中获取PatternStream？
浏览 9提问于2017-12-19得票数 0
我有一个数据表，其中事件的顺序是重要的。时间特性被设置为EventTime，因为传入记录中有时间戳。如果我正确理解，我需要为我的事件分配水印，如果我想保持按时间戳排序的流。这很简单。但我读到即使这样也不能保证秩序？因此，我使用了一个Flat
浏览 2提问于2018-11-05得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
