scala - 为什么recommendedProductsForUsers 不是 org.apache.spark.mllib.recommendation.MatrixFactorizationModel 的成员

Question

我已经使用带有 ALS collaboratife 过滤 mllib 的 Spark 构建了推荐系统

我的代码段：

bestModel.get
 .predict(toBePredictedBroadcasted.value)

evrything 没问题，但我需要更改代码来满足要求，我从这里的 scala doc 中读到

我需要使用def recommendProducts

但是当我尝试我的代码时：

bestModel.get.recommendProductsForUsers(100)

编译时出错：

value recommendProductsForUsers is not a member of org.apache.spark.mllib.recommendation.MatrixFactorizationModel
[error]     bestModel.get.recommendProductsForUsers(100)

也许任何人都可以帮助我

谢谢

注意：我使用 Spark 1.5.0

我的进口：

import com.datastax.spark.connector._
import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.SparkContext._
import java.io.File
import scala.io.Source
import org.apache.log4j.Logger
import org.apache.log4j.Level
import org.apache.spark.rdd._
import org.apache.spark.mllib.recommendation.{ALS, Rating, MatrixFactorizationModel}
import org.apache.spark.sql.SQLContext
import org.apache.spark.broadcast.Broadcast