Flink组件三:window

3.Window CountWindow TimeWindow 滚动窗口、滑动窗口、会话session窗口 3.1window的类型 3.1.1.countWindow使用 3.2.timeWindow使用 3.3.自定义window 3.2.window聚合 3.2.1.增量聚合 窗口中每进入一条数据,就进行一次计算 reduce(reduceFunction) aggregate(aggreg
相关文章
相关标签/搜索