Spark 流式计算电商商品关注度

会员
关注

本课程将使用Scoket来模拟用户浏览商品产生实时数据,数据包括用户当前浏览的商品以及浏览商品的次数和停留时间和是否收藏该商品。使用Spark Streaming构建实时数据处理系统,来计算当前电商平台最受人们关注的商品是哪些。适合有一定的Java编程基础以及一定得Spark知识,了解Streaming的工作机制的同学学习。

实验1
基于Spark实时计算商品关注度
知识点: 1.JavaScoket编程的基本原理 2.SparkStreaming应用的基本实现 3.DStream的基本操作 4.updateStateByKey的使用