Flink自定義窗口

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