在使用interval join的时候有一些疑问,希望大家能够帮忙解答一下
https://pic.imgdb.cn/item/62c5015b5be16ec74ac2b23f.png
官方文档中说会从两个流中的 timestamp  中取最大值,看了下源码确实是这样
https://pic.imgdb.cn/item/62c51e8b5be16ec74ae22880.png
我的问题是:
1.这里的timestamp和watermark有什么区别?
2.interval 
join中watermark是怎么计算的?两个流取最大的timestamp之后,watermark跟这个最大的timestamp是否有某种联系

回复