Flink assignAscendingTimestamps 生成水印的三個重載方法

先簡單介紹一下Timestamp 和Watermark 的概念:  1. Timestamp和Watermark都是基於事件的時間字段生成的 2. Timestamp和Watermark是兩個不同的東西,並且一旦生成都跟事件數據沒有關係了(所有即使事件中不再包含生成Timestamp和Watermark的字段也沒關係) 3. 事件數據和 Timestamp 一一對應(事件在流中傳遞以StreamR
相關文章
相關標籤/搜索