我们使用ALS在Azure火场建立我们的推荐系统。
由于计算能力的原因,我们不能为每个单独的用户输出不同的推荐列表。因此,我们将用户划分为集群,并使用ALS输出每个集群质心的推荐列表。$CholeskySolver.solve(ALS.scala:355) at org.apache.spark.ml.recommendation.ALS$$anonfun$org$apache$spark$ml$recommendation$ALS$$computeFactors$1.apply(ALS
当我在ALS上训练火花流的时候:这很糟糕。MapPartitionsRDD4在randomSplit at streaming.scala:15\提供的评级object streaming {\ val conf = new SparkConf().setAppName("ALStestTrain = ratingRDD.randomSplit(Arr
("Training the ALS model...")als = ALS(rank=rank, maxIter=iterations, implicitPrefs=True, regParam=regularization_parameter,("ALS model built!")INFO:__main__:ALS model built!INFO:__main__:Training the