flink實戰—Watermarks的原理和應用

概述 本文介紹flink的一個重要特性:水印(Watermarks)的原理,並經過實際的例子說明如何使用該特性。 環境:flink-1.7.1html 水印(Watermarks)簡介 咱們看到對事件時間(Event Time)的支持是流體系結構的核心。當計算基於事件時間時,咱們如何知道全部事件是否已經所有到達,咱們是否能夠計算並輸出窗口的結果?換句話說,咱們如何跟蹤事件時間並知道輸入流中已達到某
相關文章
相關標籤/搜索