我有一个用例:假设我想要制定一个规则，即在5分钟时间间隔内从某个IP生成的所有事件都应该转到一个特定的主题；在我的广播状态下，我可以有几个这样的规则。
浏览 16提问于2019-02-20得票数 3
1回答
我在Apache Flink的BroadcastStream中有一组规则。当新规则应用到我的事件流中时，我能够应用新规则。但是，如果我的规则像这样，我不知道该如何实现rule2> alert when count of event a is greater than 4 in a wind
浏览 1提问于2019-11-07得票数 0
对于joinHint，我们可以使用BROADCAST_HASH_FIRST:提示，第一个连接输入比第二个要小得多。REPARTITION_HASH_FIRST:提示第一个联接输入比第二个略小一些。是一样的吗？那么joinWithTiny在使用BROADCAST_HASH_FIRST？
利用这些的好处是Flink作业节省了检查连接数据大小的时间？
浏览 0提问于2015-07-17得票数 4
回答已采纳
2回答
我的flink应用程序执行以下操作
由: java.util.concurrent.ExecutionException: java.io.IOException
浏览 3提问于2019-01-30得票数 2
在允许的延迟期结束之前，我如何‘摆脱’窗口元数据(WindowOperator和InternalTimer)？目前使用Flink-v1.6，我们正在使用事件-时间窗口，并处理具有唯一键的大量事件。95%的事件
浏览 10提问于2019-08-19得票数 1
我已经用Flink编写了一个小测试用例代码来对数据流进行排序。但它不会输出实际排序的数字。我做错了什么？
浏览 38提问于2021-05-17得票数 0
回答已采纳
: 9:03，State: STATE_2}{Device_id: 1，时间戳: 9:00，状态: STATE_1，持续时间: 120秒}
{Device_id: 1，时间戳: 9:00
浏览 4提问于2019-11-26得票数 0
回答已采纳
1回答
这是一个关于flink流的两个问题，基于我自己做的实验，我需要一些澄清。问题如下：
假设我们在加窗的流上使用apply函数(做一些计算)，然后该流将创
浏览 1提问于2017-03-13得票数 0
回答已采纳
背景并不是每个元素都拥有唯一的id。Flink是否提供了一个API来限制状态中元素的数量？尝试过的事情
使用MapState和Sta
浏览 4提问于2022-04-07得票数 1
回答已采纳
1回答
我希望在8毫秒的窗口时间内收集输入数据流，并减少每个窗口数据。timeWindow(Time.milliseconds(8))Point数据流的关键是处理时间的时间戳映射到处理毫秒时间戳的最后但是，数据流可能到达较晚，并进入错误的窗口</
浏览 2提问于2018-07-14得票数 1
回答已采纳
我使用了10秒时间窗口，当我打印结果时，它会显示正确的结果，但是当我使用queryable状态并使用QueryableClient进行查询时，即使时间窗口发生变化，它也会缓存时间窗口的最后一个结果。例如，“Nirav”的字数为时间窗口11:00:01至11:00:10为5
<
浏览 0提问于2018-03-23得票数 1
回答已采纳
这个例子一开始非常有用，它说明了keyedProcessFunction是如何在Flink工作的它来自Fraud检测器v2: State + Time部件，对于实际的应用需求部分，在这里设置一个定时器是合理的根据flink网站:每小时处理时间窗口将包括在系统时钟指示整个小时的时间之间到达特定操作员的所有记录。例如，如果应用程序在上午9:15开始运行，则第一个每小时处理时间窗
浏览 3提问于2020-05-26得票数 0
我使用全局窗口作为我的应用程序的自定义触发器和基于某些条件的自定义驱逐器。现在，我还想把那些已经呆了太久的元素从窗口中驱逐出去，比如说30分钟。我该怎么做呢？是否有Flink提供的实用程序可以让我知道窗口中元素的使用时间？
浏览 0提问于2019-01-18得票数 0
回答已采纳
我是弗林克的新手。我有一个Flink流媒体程序，在10秒的会话窗口中计算出卡夫卡的一些内容。会话窗口默认触发器为FIRE。Flink流会在内存中保留每个窗口的全部kafka消息吗?还是只保留聚合的结果。
如果我使用FIRE_AND_PURGE，什么会被清除？
浏览 4提问于2019-02-19得票数 2
回答已采纳
我正在写一个Flink流程序，其中我需要使用一些静态数据集(信息库，IB)来丰富用户事件的DataStream。例如，假设我们有一个买家的静态数据集，我们有一个传入的事件点击流，对于每个事件，我们想要添加一个布尔标志来指示事件的实施者是否是买家。由于Flink不允许在流媒体程序中使用DataSets，我如何实现以上功能？另一种选择是使用Managed Operator State来存储买家集合，但是我如何才能保持此状
浏览 3提问于2018-04-04得票数 5
1回答
我有flink作业，它使用带事件时间和水印的键控滚动窗口来聚合数据。让我们举一个例子：
event1 =
浏览 2提问于2022-03-09得票数 0
回答已采纳
1回答
我是新的flink和寻求建立一个实时事件相关系统的建议。我有两个主要用途：
事件关联逻辑包括基于输入流中的事件类型的静态规则。最后，根据这些规则，将不同事件类型的事件与具有业务价值的事件输出数据进行关联。例如，在最后1分钟内，检查市场A1中事件类型A的价格是否小于20,000，市场M2中事件类型B的价格是否小于30,000，然后将事件A<em
浏览 2提问于2021-03-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
