JoanFM commented on a change in pull request #26523: [SPARK-29877][GRAPHX]
static PageRank allow checkPoint from previous computations
URL: https://github.com/apache/spark/pull/26523#discussion_r348175804
##########
File path: graphx/src/main/scala/org/apache/spark/graphx/GraphOps.scala
##########
@@ -424,6 +424,18 @@ class GraphOps[VD: ClassTag, ED: ClassTag](graph:
Graph[VD, ED]) extends Seriali
PageRank.run(graph, numIter, resetProb)
}
+ /**
+ * Run PageRank for a fixed number of iterations returning a graph with
vertex attributes
+ * containing the PageRank and edge attributes the normalized edge weight,
optionally including
+ * including a previous pageRank computation to be used as a start point for
the new iterations
+ *
+ * @see
[[org.apache.spark.graphx.lib.PageRank$#runWithOptionsWithPreviousPageRank]]
+ */
+ def staticPageRank(numIter: Int, resetProb: Double,
Review comment:
Well, to have another version of staticPageRank, it seem natural to have in
the same place as the function it overloads, also it needs to be visible from
Graph.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
