diff options
| author | Michael Malak <michaelmalak@yahoo.com> | 2015-04-11 21:01:23 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-11 21:01:23 -0700 |
| commit | 1205f7ea6165089985edf46ea4d2d53975d0f1f4 (patch) | |
| tree | aae17c5f4c12dc06a936d1a6d3c3a2df1a3db088 /graphx/src | |
| parent | dea5dacc5d701c3dfe433360b2e17e50edec31e8 (diff) | |
| download | spark-1205f7ea6165089985edf46ea4d2d53975d0f1f4.tar.gz spark-1205f7ea6165089985edf46ea4d2d53975d0f1f4.tar.bz2 spark-1205f7ea6165089985edf46ea4d2d53975d0f1f4.zip | |
SPARK-6710 GraphX Fixed Wrong initial bias in GraphX SVDPlusPlus
Author: Michael Malak <michaelmalak@yahoo.com>
Closes #5464 from michaelmalak/master and squashes the following commits:
9d942ba [Michael Malak] SPARK-6710 GraphX Fixed Wrong initial bias in GraphX SVDPlusPlus
Diffstat (limited to 'graphx/src')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala index 1a7178b82e..3b0e1628d8 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala @@ -93,7 +93,7 @@ object SVDPlusPlus { val gJoinT0 = g.outerJoinVertices(t0) { (vid: VertexId, vd: (Array[Double], Array[Double], Double, Double), msg: Option[(Long, Double)]) => - (vd._1, vd._2, msg.get._2 / msg.get._1, 1.0 / scala.math.sqrt(msg.get._1)) + (vd._1, vd._2, msg.get._2 / msg.get._1 - u, 1.0 / scala.math.sqrt(msg.get._1)) }.cache() materialize(gJoinT0) g.unpersist() |