aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWang Jianping J <jianping.j.wang@gmail.com>2013-12-17 19:30:07 +0800
committerWang Jianping J <jianping.j.wang@gmail.com>2013-12-17 19:30:07 +0800
commit9d2351f501b47d02399391475a57ee19ac2a28e1 (patch)
treecb6c593ea5939c8a41a70460ee479f53a63f3359
parentaee71156f324950f6e545c572d4fd6748353679a (diff)
downloadspark-9d2351f501b47d02399391475a57ee19ac2a28e1.tar.gz
spark-9d2351f501b47d02399391475a57ee19ac2a28e1.tar.bz2
spark-9d2351f501b47d02399391475a57ee19ac2a28e1.zip
Update Svdpp.scala
-rw-r--r--graph/src/main/scala/org/apache/spark/graph/algorithms/Svdpp.scala3
1 files changed, 1 insertions, 2 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 28ccaa89a9..a0f025d708 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
@@ -65,7 +65,7 @@ object Svdpp {
val u = rs / rc // global rating mean
// make graph
- var g = Graph.fromEdges(edges, defaultF(rank), RandomVertexCut).cache()
+ var g = Graph.fromEdges(edges, defaultF(rank)).cache()
// calculate initial norm and bias
val t0 = g.mapReduceTriplets(mapF0, reduceF0)
@@ -96,7 +96,6 @@ object Svdpp {
val itmBias = 0.0
val usrBias = 0.0
var pred = u + usr.bias + itm.bias + q.dotProduct(usr.v2)
- println(pred)
pred = math.max(pred, minVal)
pred = math.min(pred, maxVal)
val err = et.attr - pred