File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
graphx/src/main/scala/org/apache/spark/graphx Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -20,10 +20,10 @@ package org.apache.spark.graphx
2020import scala .reflect .ClassTag
2121import scala .util .Random
2222
23+ import org .apache .spark .ml .linalg .Vector
2324import org .apache .spark .SparkException
2425import org .apache .spark .graphx .lib ._
2526import org .apache .spark .rdd .RDD
26- import org .apache .spark .ml .linalg .Vector
2727
2828/**
2929 * Contains additional functionality for [[Graph ]]. All operations are expressed in terms of the
Original file line number Diff line number Diff line change @@ -21,9 +21,9 @@ import scala.reflect.ClassTag
2121
2222import breeze .linalg .{Vector => BV }
2323
24- import org .apache .spark .ml .linalg .{Vectors , Vector }
25- import org .apache .spark .graphx ._
24+ import org .apache .spark .ml .linalg .{Vector , Vectors }
2625import org .apache .spark .internal .Logging
26+ import org .apache .spark .graphx ._
2727
2828/**
2929 * PageRank algorithm implementation. There are two implementations of PageRank implemented.
@@ -239,7 +239,7 @@ object PageRank extends Logging {
239239 }
240240
241241 rankGraph
242- .mapVertices { (vid, attr) =>
242+ .mapVertices { (vid, attr) =>
243243 Vectors .fromBreeze(attr)
244244 }
245245 }
You can’t perform that action at this time.
0 commit comments