Flink实时项目例程_aggregate(new countagg(), new windowresultfunction-CSDN博客

网站介绍:文章浏览阅读1.5k次,点赞2次,收藏6次。Flink实时项目例程一、项目模块完整例程github地址:https://github.com/HeCCXX/UserBehaviorAnalysis.gitHotItemAnalysis 模块 : 实时热门商品统计,输出Top N 的点击量商品,利用滑动窗口,eventTime(包括本地文件数据源和kafka数据源)NetWorkTrafficAnalysis 模块,实时流量统计,和..._aggregate(new countagg(), new windowresultfunction())aggregate(new countagg(