95-190-730-源码-WindowFunction-窗口操作符侧的窗口函数(内部函数)

1.世界 2.概述 ​ 窗口操作符本质上就是一个流操作符,也是通过 processElement 来处理流元素,只是一般的操作符执行窗口函数之后就 emit 结果到下游了,窗口操作符通过 trigger 设置定时器,当定时器触发的时候,取出窗口中保存的数据,执行窗口函数并 emit 结果到下游(其实窗口操作符有些类似于之前讲过的异步操作符) ​ 窗口流(由 DataStream 转换得到,下一篇文
相关文章
相关标签/搜索