如何使用Spark ALS实现协同过滤

norybaby · 发表于 2015-12-9 11:02:50

谢谢分享

tianjixiaoying · 发表于 2015-12-21 18:42:40

学习下spark机器学习，谢谢

zfh01234 · 发表于 2016-1-4 11:12:53

楼主辛苦！

110469634 · 发表于 2016-1-8 16:40:10

xiexiexiexie

heiyanjinger · 发表于 2016-2-29 16:32:22

写的很好，楼主

xiaoben_319 · 发表于 2016-4-1 12:12:18

写的太好了，只是有些地方不太懂，还得继续看原理啊

aurae · 发表于 2016-4-21 16:24:25

学习一下

aurae · 发表于 2016-4-21 16:38:32

楼主你好，我执行您发的帖子，执行到这里。发现两个问题：
1.查看该用户的评分记录：

val goodsForUser=ratings.keyBy(_.user).lookup( 384 )

productsForUser.size //Int = 22

这块代码，先定义了goodsForUser，但紧接着就使用了productsForUser。我看了全文，并没有代码块定义了productsForUser这个变量，是不是这块goodsForUser定义错了，实际上是需要定义productsForUser的？

2.import org.jblas.DoubleMatrix 这个包引用失败，提示error: object jblas is not a member of package org 。是不是引包引的不对，或者缺少jar包？

lovebyz · 发表于 2016-4-22 10:14:05

aurae 发表于 2016-4-21 16:38
楼主你好，我执行您发的帖子，执行到这里。发现两个问题：
1.查看该用户的评分记录：
val goodsForUser=r ...

是的，是productsForUser. 定义的名字换了一下，后面都用这个就没问题了

lovebyz · 发表于 2016-4-22 10:16:25

aurae 发表于 2016-4-21 16:38
楼主你好，我执行您发的帖子，执行到这里。发现两个问题：
1.查看该用户的评分记录：
val goodsForUser=r ...

jblas是一个外部包，支持线性代数，并不在spark的库里，使用是要先导入这个包

图文精华