Flink 两种发送自定义的timestamp以及watermark的方式

Flink提供了抽象类来让开发者赋值本身的时间戳并发送他们本身的Watermark。更具体来讲，开发者须要依照不一样用例状况来实现接口AssignerWithPeriodicWatermarks或接口AssignerWithPunctuatedWatermarks。简而言之，前一个接口将会周期性发送Watermark，而第二个接口根据一些到达数据的属性，例如一旦在流中碰到一个特殊的element便

>>阅读原文<<