电影数据:pyspark 协同过滤矩阵分解ALS

须要注意代码里long(p[3])改为float ratingsRDD = parts.map(lambda p: Row(userId=int(p[0]), movieId=int(p[1]), rating=float(p[2]), timestamp=float(p[3])))代码：html from pyspark import SparkContext, SparkConf from p

>>阅读原文<<