create pr

zhengruifeng · zhengruifeng · commit 7e62b55c2331 · 2016-05-12T17:20:44.000+08:00
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
@@ -196,9 +196,7 @@ object SVDPlusPlus {
     g.unpersist()
     g = gJoinT3
 
-    // Convert DoubleMatrix to Array[Double]:
-    val newVertices = g.vertices.mapValues(v => (v._1.toArray, v._2.toArray, v._3, v._4))
-    (Graph(newVertices, g.edges), u)
+    (g, u)
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -196,9 +196,7 @@ object SVDPlusPlus {`
`196`	`196`	`g.unpersist()`
`197`	`197`	`g = gJoinT3`
`198`	`198`
`199`		`- // Convert DoubleMatrix to Array[Double]:`
`200`		`- val newVertices = g.vertices.mapValues(v => (v._1.toArray, v._2.toArray, v._3, v._4))`
`201`		`- (Graph(newVertices, g.edges), u)`
	`199`	`+ (g, u)`
`202`	`200`	`}`
`203`	`201`
`204`	`202`	`/**`