聊聊Flink必知必会(五)
[*]聊聊Flink的必知必会(三)
[*]聊聊Flink必知必会(四)
从源码中，根据关键的代码，梳理一下Flink中的时间与窗口实现逻辑。
WindowedStream
对数据流执行keyBy()操作后，再调用window()方法，就会返回WindowedStream，表示分区后又加窗的数据流。如果数据流没有经过分区，直接调用window()方法则会返回AllWindowedStream。
如下：
// 构造函数public WindowedStream(KeyedStream input, WindowAssigner
页:
[1]