ToB企服应用市场:ToB评测及商务社交产业平台

标题: 聊聊Flink必知必会(五) [打印本页]

作者: 郭卫东 时间: 2023-12-24 07:05
标题: 聊聊Flink必知必会(五)

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

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

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

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)