Flink系列之Time和WaterMark

　　當數據進入Flink的時候，數據需要帶入相應的時間，根據相應的時間進行處理。 　　讓咱們想象一個場景，有一個隊列，分別帶着指定的時間，那麼處理的時候，需要根據相應的時間進行處理，比如：統計最近五分鐘的訪問量，那麼就需要知道數據到來的時間。五分鐘以內的數據將會被計入，超過五分鐘的將會計入下一個計算窗口。 　　那麼Flink的Time分爲三種： 　　ProcessingTime ： 處理時間，即算

>>阅读原文<<