【Flink】Flink的事件時間及watermark水印講解-附代碼實例

Flink支持根據事件時間處理，數據流中的每條數據都須要具備各自的時間戳，表明着數據的產生時間【事件時間】。java 在分佈式系統中，數據流的採集一般都是有延遲的，多是網絡緣由啊，程序緣由啊什麼的。因此當數據到達Flink程序中的時候，問題就來了，這些數據都要進行處理嗎？有可能其中一部分數據已經延遲了好幾個小時了，這對於實時性較強的業務場景是不能容忍的！git 這時候水印就應運而生了，水印的目的就

>>阅读原文<<