Dataret没有sortBy方法怎么解决

Question

我的代码是
import org.apache.spark.sql.hive.HiveContext
val hiveCtx = new org.apache.spark.sql.hive.HiveContext(sc)

val inputPath = "/input/cleanMealRatings"
val cleanMealData = hiveCtx.jsonFile(inputPath)

val MealRatings = cleanMealData.select("UserID","MealID","Rating","ReviewTime")
val RatingRDD = MealRatings.map(row => (row.getString(0),row.getString(1),row.getDouble(2),row.getLong(3)))

val userZipCode = RatingRDD.map(_._1).distinct.sortBy(x=>x).zipWithIndex.map(data=>(data._1,data._2.toInt))
他到这里会报一个错误

这个该怎么解决

Answer 1

API的版本太老了，这边建议亲换个新的API算子。