我的代码是
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))
他到这里会报一个错误
这个该怎么解决