Flink自定義窗口

先看官方的Flink自定義窗口流程： 基本操做以下：app window：建立自定義窗口 trigger：自定義觸發器 evictor：自定義evictor apply：自定義window function 從定義窗口的基本操做能夠看出，先調用window函數，定義一個WindowAssigner對象，  在WindowAssigner中 經過 assignWindows 設定窗口類型，而後基於t

>>阅读原文<<