Apache Flink,事件时间聚合-水印是否与聚合密钥相关联？
当我们进行基于事件时间的聚合时，有一个实时的数据流--某个键的事件的水印会触发其他键的窗口操作吗？
id 1 at 12:00
id 1 at 12:08
id 2 at 12:15
id 1 at 12:20
id为2的事件是否会触发id为1的12:00-12:10的时间窗口？或者只有在12:20下一个id为1的事件到达时才会发生？
共有1个答案
水印不与密钥相关联--它们是按流的，或者在Kafka的情况下，它们可以是按Kafka分区的--所以是的，基于一个密钥的事件生成的水印也会触发其他密钥的窗口。
每键水印是Flink社区中已经讨论过的东西，有一天可能会发生，但在Flink1.5中，情况就是这样。
-
我有一个条目主题，其中我从传感器接收数据。通常，我收到的数据如下所示： 为了稍后在拓扑中进行一些计算，我需要构建一个映射，其中包含从每个捕获者接收到的所有最后值。 关键字：项目id值：{ 为了做到这一点，我在传感器主题和聚合主题之间进行了连接，连接的结果是聚合主题中的post。 ------ 传感器（KStream）-| -------聚合（KTable）---| 更新：以下是实现这种连接的jav
-
问题内容： 我试图理解这些术语的含义。我举了一些例子，例如： 汇总：Facebook 有一个 用户 组成：facebook 中的 每个用户 都有一个 会话。 协会：人们 使用 浏览器 但是我对 具有 和 使用我的 示例感到困惑。为什么不能是用户 使用 Facebook帐户或Facebook 使用 会话来认证用户？ 就OOP而言，这是错误的吗？我在哪里想念这个概念？ 问题答案： 该 使用 关系意味着
-
我将Flink 1.11.3与SQL API和Blink planner结合使用。我在流模式下工作，使用带有文件系统连接器和CSV格式的CSV文件。对于一个时间列，我生成水印，并希望根据这个时间进行窗口聚合。就像根据事件时间快进过去一样。 是否必须为此对时间列进行排序，因为逐行使用时间列，如果不进行排序，可能会发生延迟事件，从而导致行的删除？ 我对Ververica的CDC连接器也很感兴趣。也许我
-
当您的事件需要附加到更多侦听器或需要观察应用程序的某些功能并等待数据更新时，应使用事件聚合器。 Aurelia事件聚合器有三种方法。 publish方法将触发事件，并可供多个订阅者使用。 对于订阅事件，我们可以使用subscribe方法。 最后，我们可以使用dispose方法分离订阅者。 以下示例演示了这一点。 我们的视图将为三个功能中的每一个提供三个按钮。 app.html <template>
-
本文向大家介绍Java中关联与聚合之间的区别，包括了Java中关联与聚合之间的区别的使用技巧和注意事项，需要的朋友参考一下 协会 就对象而言，关联是指两个相关对象之间的“具有”关系。例如，一个雇员有一个通讯地址。 聚合 就对象而言，聚合是指两个相关对象之间具有“ +”关系。例如，一个部门有多名员工。它指的是在父类中具有子对象的集合。例如： 序号 键 协会 聚合 1 定义 关联是指彼此使用的两个类之
-
我开始研究 OOAD，我很难找到一个 代码示例来说明如何以编程方式实现、和。（到处都有几篇文章，但它们与 C# 或 Java 有关）。我确实找到了一两个例子，但它们都与我的导师的指示相冲突，我很困惑。 我的理解是，在: < li >关联:Foo有一个指向Bar对象的指针作为数据成员 < li >聚合:Foo有一个指向Bar对象的指针，Bar的数据被深度复制到该指针中。 < li >组成:Foo有一