【Flink系列2】時間窗口

引出 對於流處理系統來講，流入的消息是無限的，因此對於聚合或是鏈接等操做，流處理系統須要對流入的消息進行分段，而後基於每一段數據進行聚合或是鏈接等操做。消息的分段即稱爲窗口，流處理系統支持的窗口有不少類型，最多見的就是時間窗口，基於時間間隔對消息進行分段處理。本節主要介紹Flink流處理系統支持的各類時間窗口。緩存 對於目前大部分流處理系統來講，時間窗口通常是根據Task所在節點的本地時鐘來進行切

>>阅读原文<<