Flink流計算編程--watermark（水位線）簡介

一、watermark的概念 watermark是一種衡量Event Time進展的機制，它是數據自己的一個隱藏屬性。一般基於Event Time的數據，自身都包含一個timestamp，例如1472693399700（2016-09-01 09:29:59.700），而這條數據的watermark時間則多是：html watermark(1472693399700) = 147269339670

>>阅读原文<<