网站日志实时分析之处理实时热门和统计
实时热门统计 操作步骤: 先从Kafka读取消费数据 使用map算子对数据进行预处理 过滤数据,只留住pv数据 使用timewindow,每隔10秒创建一个20秒的window 然后将窗口自定义预聚合,并且兹定于窗口函数,按指定输入输出case操作数据 上面操作时候返回的是DataStream……
专注于Android、Java、Go语言(golang)、移动互联网、项目管理、软件架构