首页 > > > flink window实例分析-2
1. 定义时间戳,上篇文章<flink中的时间戳如何使用?---Watermark使用及原理>上进行了介绍,本篇不做赘述。
2.窗口类型,Windows Assigner定义如何将数据流分配到一个或者多个窗口;其层次结构如下:

evictor:用于数据剔除,其层次结构如下:

3. trigger:窗口触发器,其层次结构如下:

4. Window function定义窗口内数据的计算逻辑,其层次结构如下:

来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/2730/viewspace-3154882/ ,如需转载,请注明出处,否则将追究法律责任。