Flink实战:用户行为分析之热门商品TopN统计
环境 ubuntu14、flink1.7.2、scala2.11、kafka2.3.0、jdk1.8、idea2019 步骤 抽取出业务时间戳,告诉 Flink 框架基于业务时间做窗口 过滤出点击行为(pv)数目 按一小时的窗口大小,每 5 分钟统计一次,做滑动窗口聚合(Sliding Window) 按每个窗口聚合,输出每个窗口中点击量前 N 名的商品 实现 创建maven项目,命名UserBehaviorAnalysis,其pom内容如下: 4.0.0 com.ustc UserBehaviorAnalysis pom 1.0-SNAPSH
暂无评论