Flink流计算编程--watermark（水位线）简介

【本文转自Flink流计算编程--watermark（水位线）简介】html 一、watermark的概念 watermark是一种衡量Event Time进展的机制，它是数据自己的一个隐藏属性。一般基于Event Time的数据，自身都包含一个timestamp，例如1472693399700（2016-09-01 09:29:59.700），而这条数据的watermark时间则多是：java

>>阅读原文<<