《Spark商业案例与性能调优实战100课》第13课:商业案例之纯粹通过DataSet进行电商交互式分析系统中特定时段段访问次数TopN
2017-01-21 20:52
1151 查看
《Spark商业案例与性能调优实战100课》第13课:商业案例之纯粹通过DataSet进行电商交互式分析系统中特定时段段访问次数TopN
明晚起课程频道改变,只有加入课程的学员才可以听课。
import org.apache.spark.sql.functions._
第一个作业:通读functions.scala的源代码
第二个作业:手动造出数据
json 读入文件直接转换为dataSet
通用模式: join =〉groupby => agg =>sort => show
val userInfo=spark.read.format("json").json("Json file's path ...")
val userAccessLog=spark.read.format("json").json("Json file's path ...")
userAccessLog.filter("time >= 2017-1-1 and time <=2017-1-10")
.join(userInfo,userAccessLog("UserID")===userInfo("UserID"))
.groupby(usersInfo("UserID"),usersInfo("UserName"))
.agg(count(userAccessLog("time")).alias("userCount"))
.sort($"usercount".desc)
.limit(10)
.show()
明晚起课程频道改变,只有加入课程的学员才可以听课。
import org.apache.spark.sql.functions._
第一个作业:通读functions.scala的源代码
第二个作业:手动造出数据
json 读入文件直接转换为dataSet
通用模式: join =〉groupby => agg =>sort => show
val userInfo=spark.read.format("json").json("Json file's path ...")
val userAccessLog=spark.read.format("json").json("Json file's path ...")
userAccessLog.filter("time >= 2017-1-1 and time <=2017-1-10")
.join(userInfo,userAccessLog("UserID")===userInfo("UserID"))
.groupby(usersInfo("UserID"),usersInfo("UserName"))
.agg(count(userAccessLog("time")).alias("userCount"))
.sort($"usercount".desc)
.limit(10)
.show()
相关文章推荐
- 《Spark商业案例与性能调优实战100课》第14课:商业案例之纯粹通过DataSet进行电商交互式分析系统中特定时段购买金额Top10 和访问次数增长Top10
- 《Spark商业案例与性能调优实战100课》第15课:商业案例之纯粹通过DataSet进行电商交互式分析系统中各种类型TopN分析实战详解
- 通过DataSet进行电商交互式分析系统中特定时段段访问次数TopN
- Spark商业案例与性能调优实战100课》第11课:商业案例之通过纯粹通过DataFrame分析大数据电影点评系仿QQ和微信、淘宝等用户群分析与实战
- Spark商业案例与性能调优实战100课》第2课:商业案例之通过RDD实现分析大数据电影点评系统中电影流行度分析
- Spark商业案例与性能调优实战100课》第2课:商业案例之通过RDD实现分析大数据电影点评系统中电影流行度分析
- Spark商业案例与性能调优实战100课》第3课:商业案例之通过RDD分析大数据电影点评系各种类型的最喜爱电影TopN及性能优化技巧
- 《Spark商业案例与性能调优实战100课》第1课:商业案例之通过RDD实现分析大数据电影点评系统中电影的用户行为信息
- <<《Spark商业案例与性能调优实战100课》第17课:商业案例之NBA篮球运动员大数据分析系统代码实战
- 《Spark商业案例与性能调优实战100课》第6课:商业案例之通过Spark SQL实现大数据电影用户行为分析
- Spark商业案例与性能调优实战100课》第16课:商业案例之NBA篮球运动员大数据分析系统架构和实现思路
- 《Spark商业案例与性能调优实战100课》第9课:商业案例之通过Spark SQL 下两种不同方式实现口碑最佳和最热门电影比较
- Spark商业案例与性能调优实战100课》第20课:大数据性能调优的本质和Spark性能调优要点分析
- 《Spark商业案例与性能调优实战100课》第18课:商业案例之NBA篮球运动员大数据分析代码实战之核心基础数据项编写
- 《Spark商业案例与性能调优实战100课》第19课:商业案例之NBA篮球运动员大数据分析核心业务逻辑代码实战
- 《Spark商业案例与性能调优实战100课》第21课:Spark性能调优之系统资源使用原理和调优最佳实践
- 《Spark商业案例与性能调优实战100课》第28课:彻底解密Spark Sort-Based Shuffle排序具体实现内幕和源码详解
- 《Spark商业案例与性能调优实战100课》第25课:Spark Hash Shuffle源码解读与剖析
- Spark商业案例与性能调优实战100课》第22课:Spark性能调优之使用更高性能算子及其源码剖析
- 《Spark商业案例与性能调优实战100课》第27课:彻底解密Spark Shuffle令人费解的6大经典问题