时间:2021-07-01 10:21:17 帮助过:51人阅读
评级文件ratings.dat的格式描述如下:
1. userid::movieid::rating::timestamp
2. 用户id、电影id、评分数据、时间戳
电影文件movies.dat的格式描述如下:
1. movieid::title::genres
2. 电影id、电影名、电影类型
1、首先使用RDD方式读取数据
1、val usersRDD = sc.textfile(dataPath+"users.dat") 2、val moviesRDD = sc.textfile(dataPath+"movies.dat") 3、val occupationsRDD = sc.textfile(dataPath+"occupations.dat") 4、val ratingsRDD = sc.textfile(dataPath+"ratings.dat")
spark之通过sparksql中的SQL语句实现电影点评系统用户行为分析
标签:movies 时间戳 div span tin cup 职业 user 系统用户