spark操作mongodb 遇到的问题

我需要从一个
case class Rating(val uid: Int, val mid: Int, val score: Double, val timestamp: Int)
表中取出用户最近看过的10个电影的数据
难点:需要的不是一个用户是所有用户
case class介绍
样例类(case class)适合用于不可变的数据。它是一种特殊的类,能够被优化以用于模式匹配。
 
首先创建两个样例类
case class RentlyMovie(val mid: Int, val score: Double, val timestamp: Int)
 
case class UserRentlyMovie(val uid: Int, recs: Seq[RentlyMovie])
 编写业务逻辑
import spark.implicits._
val redisData = spark.read
.option("uri", config("mongo.url"))
.option(

spark操作mongodb 遇到的问题最先出现在Python成神之路

版权声明:
作者:congcong
链接:https://www.techfm.club/p/19257.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>