1. 首页
  2. 数据库
  3. 其它
  4. Flink实战:用户行为分析之热门商品TopN统计

Flink实战:用户行为分析之热门商品TopN统计

上传者: 2021-02-19 07:30:30上传 PDF文件 120.15KB 热度 11次
环境 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
用户评论