You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/04/12 06:01:26 UTC
spark git commit: SPARK-6710 GraphX Fixed Wrong initial bias in
GraphX SVDPlusPlus
Repository: spark
Updated Branches:
refs/heads/master dea5dacc5 -> 1205f7ea6
SPARK-6710 GraphX Fixed Wrong initial bias in GraphX SVDPlusPlus
Author: Michael Malak <mi...@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
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/1205f7ea
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/1205f7ea
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/1205f7ea
Branch: refs/heads/master
Commit: 1205f7ea6165089985edf46ea4d2d53975d0f1f4
Parents: dea5dac
Author: Michael Malak <mi...@yahoo.com>
Authored: Sat Apr 11 21:01:23 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sat Apr 11 21:01:23 2015 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/1205f7ea/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala
----------------------------------------------------------------------
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 1a7178b..3b0e162 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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org