Apache Flink中周期性水印和标点水印的区别是什么？
如果有人用下面给出的Apache flink给出usecase示例来解释每个水印API之间的差异，这将是有帮助的
- 周期水印-
assignerwithperiodiaWatermarks[T] - 标点符号水印-
assignerwith标点符号水印[T]
共有1个答案
这两种水印的主要区别在于如何/何时调用getWatermark方法。
周期水印
使用周期性水印，Flink会定期调用getCurrentWatermark()，与事件流无关。此间隔使用
ExecutionConfig.setAutoWatermarkInterval(millis)
-
我读到，“...排序运算符必须缓冲它收到的所有元素。然后，当它收到水印时，它可以对时间戳低于水印的所有元素进行排序，并按排序顺序发出它们。这是正确的，因为水印表明不会有更多的元素到达，这些元素会与排序的元素混合在一起......”-流中的https://cwiki.apache.org/confluence/display/FLINK/Time和顺序 因此，水印似乎可以作为信号发送给以下操作符，以
-
在Flink中，我发现了2种设置水印的方法， 第一个是 第二个是 我想知道哪个最终会生效。
-
Sometimes you just want to write some text on top of an image. The following examples demonstrate using some of the text functions included with watermark.js. In the interest of saving space, the foll
-
A common use case for watermarking is to lay one image on top of another. The following examples demonstrate some of the pre-packaged image positioning functions that come with watermark.js. Lower Rig
-
可以在您将要上传的视频每一帧打上水印，以便版权保护。 进入视频水印页面，可以进行水印编辑。 注：只对水印开启后上传的视频生效。 编辑水印页面：
-
我看到关于为每个密钥添加水印支持的讨论很多。但是flink支持每个分区的水印吗？ 当前-然后考虑所有水印（非空闲分区）的最小值。因此，窗口中最后挂起的记录也被卡住了。（使用periodicemit增加水印时） 任何关于这方面的信息都非常感谢！