ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

fixing the the silly bug in the dynamic pagerank gather function

Browse source
This commit is contained in:
Joseph E. Gonzalez 2013-04-04 19:24:06 -07:00
parent b537613570
commit d510045d8c
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
graph/src/main/scala/spark/graph/Analytics.scala
View file

@ -43,7 +43,7 @@ object Analytics {
/**
* Compute the PageRank of a graph returning the pagerank of each vertex as an RDD
*/
def dynamicPageRank[VD: Manifest, ED: Manifest](graph: Graph[VD, ED],
def dynamicPagerank[VD: Manifest, ED: Manifest](graph: Graph[VD, ED],
tol: Float, maxIter: Int = 10) = {
// Compute the out degree of each vertex
val pagerankGraph = graph.updateVertices[Int, (Int, Float, Float)](graph.outDegrees,
@ -52,7 +52,7 @@ object Analytics {
// Run PageRank
GraphLab.iterateGAS(pagerankGraph)(
(me_id, edge) => edge.src.data._2 / edge.dst.data._1, // gather
(me_id, edge) => edge.src.data._2 / edge.src.data._1, // gather
(a: Float, b: Float) => a + b,
(vertex, a: Option[Float]) =>
(vertex.data._1, (0.15F + 0.85F * a.getOrElse(0F)), vertex.data._2), // apply