Flink中的水印和触发器有什么区别？

Question

我读到，“...排序运算符必须缓冲它收到的所有元素。然后，当它收到水印时，它可以对时间戳低于水印的所有元素进行排序，并按排序顺序发出它们。这是正确的，因为水印表明不会有更多的元素到达，这些元素会与排序的元素混合在一起......”-流中的https://cwiki.apache.org/confluence/display/FLINK/Time和顺序

因此，水印似乎可以作为信号发送给以下操作符，以便开始处理。我想，这也是触发器的作用。这两者有什么区别？

Answer 1

水印可以被认为是一种断言，即事件时间流现在在特定时间戳之前是完整的。当操作员处理水印时，它将导致触发任何相关事件时间计时器。使用EventTimer的操作符是EventTimeWindows和ProcessFunctions。

触发器是窗口API的一部分，用于定义Windows何时生成结果。EventTimeTrigger围绕一个事件时间计时器，该计时器在处理适当大的水印时调用，表示窗口现在已完成。

Answer 2

您可以将水印视为告诉操作员它是什么（事件）时间的特殊记录。当操作员收到水印时，它会将水印与其当前时间和从不同流分区收到的其他水印进行比较。根据比较，操作员会提前自己的时钟。

一些操作员注册计时器（windows、基于时间的联接、自定义实现）。当操作员的时钟超过计时器注册的时间时，操作员触发计时器。

所以，水印和计时器是两回事。水印告诉操作员现在是什么时间，操作员在正确的时间点触发计时器。