Flink源碼解讀系列 | Periodic水印和Punctuated水印實現原理

點擊上方藍色字體，選擇「設爲星標」 回覆」資源「獲取更多驚喜 大數據技術與架構 點擊右側關注，大數據開發領域最強公衆號！ 暴走大數據 點擊右側關注，暴走大數據！ 在用戶代碼中，我們設置生成水印和事件時間的方法assignTimestampsAndWatermarks（）中這裏有個方法的重載 我們傳入的對象分爲兩種 AssignerWithPunctuatedWatermarks（可以理解爲每條數據

>>阅读原文<<