Flink 窗口处理函数 WindowFunction
在之前的文章中我们已经了解了 Flink 的,并介绍了其中涉及的组件:WindowAssigner、WindowFunction、Trigger、Evictor。在中我们知道可以通过不同类型的窗口分配器 WindowAssigner 将元素分配到窗口中。在指定 WindowAssigner 后,需要在每个窗口上指定我们要执行的计算逻辑,这就是窗口函数(WindowFunction)的责任。一旦系统确定窗口准备好处理数据,窗口函数就会被调用来处理窗口中的每个元素。