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

Question

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

因此，水印似乎充当后续操作员开始处理的信号。我想，这也是触发器的作用。两者有什么区别？

Answer 1

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

一些操作符注册计时器（窗口、基于时间的连接、自定义实现）。当操作员的时钟经过计时器注册的时间时，操作员触发计时器。

因此，水印和计时器是两个不同的东西。水印告诉操作员现在是什么时间，操作员会在正确的时间点触发计时器。