From ab7b8ce13ec3a0a85f57ceede02df1e5eb9f6c23 Mon Sep 17 00:00:00 2001 From: Jianping J Wang Date: Tue, 31 Dec 2013 17:11:20 +0800 Subject: Update Svdpp.scala --- graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'graph/src') 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 7c3e0c83c9..cb1a69e318 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 @@ -71,7 +71,7 @@ object Svdpp { } for (i <- 0 until conf.maxIters) { - // phase 1, calculate v2 for user nodes + // phase 1, calculate pu + |N(u)|^(-0.5)*sum(y) for user nodes var t1 = g.mapReduceTriplets(et => Iterator((et.srcId, et.dstAttr._2)), (g1: RealVector, g2: RealVector) => g1.add(g2)) g = g.outerJoinVertices(t1) { (vid: Vid, vd: (RealVector, RealVector, Double, Double), msg: Option[RealVector]) => if (msg.isDefined) (vd._1, vd._1.add(msg.get.mapMultiply(vd._4)), vd._3, vd._4) else vd -- cgit v1.2.3