ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Update Svdpp.scala

Browse source
This commit is contained in:
Jianping J Wang 2013-12-31 17:18:15 +08:00
parent ab7b8ce13e
commit 12c26d7fb9
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala
View file

@ -96,7 +96,7 @@ object Svdpp {
}
val t3 = g.mapReduceTriplets(mapTestF(conf, u), (g1: Double, g2: Double) => g1 + g2)
g.outerJoinVertices(t3) { (vid: Vid, vd: (RealVector, RealVector, Double, Double), msg: Option[Double]) =>
if (msg.isDefined && vid % 2 == 1) (vd._1, vd._2, vd._3, msg.get) else vd
if (msg.isDefined) (vd._1, vd._2, vd._3, msg.get) else vd
}
g
}