如何将偏移窗口应用到翻滚窗口，以延迟Windows＆lt; timeWindow＆gt;在Kafka流中
我正在使用不同的窗口尺寸在2022年5月的数据集上计算一个简单的均值。使用1小时的窗户没有问题，使用1周零1个月的窗口，记录未正确评估。 如所讨论的…
弗林布林窗口中的Flink聚合功能自动在两个窗户中拆分，以实现大窗口尺寸
我使用不同的窗口尺寸在某些记录上计算一个简单的均值。使用 1小时和 1周的Windows 没有问题，并且结果计算正确。 var keyed = src .filter(event -> …
用于用户活动数据流以构建在线ML模型
我正在写一个消费的消费者（用户活动数据（ActivityId，userId，Timestamp，cta，持续时间）从Google Pub/sub，我想为此创建一个水槽，以便我可以训练…
使用 Redis 流作为 MQTT 队列
Redis 在后来的几年里发生了很大的变化，很难跟上最新的功能。 我们有几千个 IoT 设备，它们每秒都会发送 MQTT 消息。我们希望不同的消费者阅读和处理…
如何在窗口和接收器操作符之间注入延迟？
上下文 - 应用程序 我们有一个处理事件的 Apache Flink 应用程序 应用程序使用事件时间特征 应用程序分片 (keyBy) 事件基于 sessionId 字段 应用程序…
- 共 1 页
- 1
