aboutsummaryrefslogtreecommitdiff
path: root/graph/src
diff options
context:
space:
mode:
authorWang Jianping J <jianping.j.wang@gmail.com>2013-12-21 16:08:19 +0800
committerWang Jianping J <jianping.j.wang@gmail.com>2013-12-21 16:08:19 +0800
commitb4bce88a2d881d6514b6beb37e83c31afc01e53f (patch)
tree561a0b8bf36b1a0fcf114e41b3b7183e336218f6 /graph/src
parent49eb0f1351fc73bcb44fffbd30d955a95bd88fbe (diff)
downloadspark-b4bce88a2d881d6514b6beb37e83c31afc01e53f.tar.gz
spark-b4bce88a2d881d6514b6beb37e83c31afc01e53f.tar.bz2
spark-b4bce88a2d881d6514b6beb37e83c31afc01e53f.zip
Update Svdpp.scala
Diffstat (limited to 'graph/src')
-rw-r--r--graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala b/graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala
index ac20f15072..74096eb80d 100644
--- a/graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala
+++ b/graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala
@@ -138,7 +138,7 @@ object Svdpp {
// calculate error on training set
def mapF3(et: EdgeTriplet[VT, Double]): Iterator[(Vid, Double)] = {
assert(et.srcAttr != null && et.dstAttr != null)
- val (usr, item) = (et.srcAttr, et.dstAttr)
+ val (usr, itm) = (et.srcAttr, et.dstAttr)
val (p, q) = (usr.v1, itm.v1)
var pred = u + usr.bias + itm.bias + q.dotProduct(usr.v2)
pred = math.max(pred, minVal)