Flink動態窗口(二)

第一篇地址 前面一篇只寫了思路來源,不是很明確做法. 有些朋友有緣看到了不是很明白,後面換了種簡單高效的方式,匆忙記錄一下 下面只描述了滾動窗口的做法,滑動窗口做法類似 自定義WindowAssigner AsyncParamRequestFunction 繼承 RichAsyncFunction 使用flink的異步IO獲取到窗口大小等動態數據放到對應的元素中. 其中使用了定時過期的Guava

>>阅读原文<<