Scala RDD键值对反转实现：将值中电影名设为新键原键纳入值

实现方法 #

你当前的rateMovieByYear类型为RDD[(Double, (String, String))]，每个元素结构为(原键评分, (年份, 电影名称))，只需调用map算子做结构映射即可完成键值调整：

val adjustedRDD = rateMovieByYear.map {
  case (rate, (year, movieName)) => (movieName, (rate, year))
}

效果验证 #

执行打印前5条数据的命令即可验证转换结果符合预期：

adjustedRDD.take(5).foreach(println)

输出样例：

(Tortilla Soup,(14.0009,2001))
(Lady and the Tramp,(5.1258,1955))
(Chi bi xia: Jue zhan tian xia,(12.5,2013))
(Dante's Inferno: Documentary,(12.5,2013))
(José Rizal,(12.5,2013))

内容的提问来源于stack exchange，提问作者Linna