聊聊Flink必知必会(五)

• 聊聊Flink的必知必会(三)
  
• 聊聊Flink必知必会(四)
  

从源码中，根据关键的代码，梳理一下Flink中的时间与窗口实现逻辑。
WindowedStream

对数据流执行keyBy()操作后，再调用window()方法，就会返回WindowedStream，表示分区后又加窗的数据流。如果数据流没有经过分区，直接调用window()方法则会返回AllWindowedStream。
如下：
[code]// 构造函数public WindowedStream(KeyedStream input, WindowAssigner