Flink动态窗口(二)

第一篇地址 前面一篇只写了思路来源,不是很明确做法. 有些朋友有缘看到了不是很明白,后面换了种简单高效的方式,匆忙记录一下 下面只描述了滚动窗口的做法,滑动窗口做法类似 自定义WindowAssigner AsyncParamRequestFunction 继承 RichAsyncFunction 使用flink的异步IO获取到窗口大小等动态数据放到对应的元素中. 其中使用了定时过期的Guava
相关文章
相关标签/搜索