Flink 兩種發送自定義的timestamp以及watermark的方式

Flink提供了抽象類來讓開發者賦值本身的時間戳併發送他們本身的Watermark。更具體來講，開發者須要依照不一樣用例狀況來實現接口AssignerWithPeriodicWatermarks或接口AssignerWithPunctuatedWatermarks。簡而言之，前一個接口將會週期性發送Watermark，而第二個接口根據一些到達數據的屬性，例如一旦在流中碰到一個特殊的element便

>>阅读原文<<