95-190-730-源碼-WindowFunction-窗口操作符側的窗口函數(內部函數)

1.世界 2.概述 ​ 窗口操作符本質上就是一個流操作符,也是通過 processElement 來處理流元素,只是一般的操作符執行窗口函數之後就 emit 結果到下游了,窗口操作符通過 trigger 設置定時器,當定時器觸發的時候,取出窗口中保存的數據,執行窗口函數並 emit 結果到下游(其實窗口操作符有些類似於之前講過的異步操作符) ​ 窗口流(由 DataStream 轉換得到,下一篇文
相關文章
相關標籤/搜索