Flink流計算編程--watermark(水位線)簡介

【本文轉自Flink流計算編程--watermark(水位線)簡介】html 一、watermark的概念 watermark是一種衡量Event Time進展的機制,它是數據自己的一個隱藏屬性。一般基於Event Time的數據,自身都包含一個timestamp,例如1472693399700(2016-09-01 09:29:59.700),而這條數據的watermark時間則多是:java
相關文章
相關標籤/搜索