Skip to content
Snippets Groups Projects
Commit 942de984 authored by Joseph E. Gonzalez's avatar Joseph E. Gonzalez
Browse files

Making suggested changes.

parent d6a902f3
No related branches found
No related tags found
No related merge requests found
......@@ -26,7 +26,7 @@ object Analytics extends Logging {
* for( iter <- 0 until numIter ) {
* swap(oldPR, PR)
* for( i <- 0 until n ) {
* PR[i] = alpha + (1 - \alpha) * inNbrs[i].map(j => oldPR[j] / outDeg[j]).sum
* PR[i] = alpha + (1 - alpha) * inNbrs[i].map(j => oldPR[j] / outDeg[j]).sum
* }
* }
* }}}
......@@ -193,18 +193,6 @@ object Analytics extends Logging {
sendMessage,
(a,b) => math.min(a,b)
)
/**
* Originally this was implemented using the GraphLab abstraction but with
* support for message computation along all edge directions the pregel
* abstraction is sufficient
*/
// GraphLab(ccGraph, gatherDirection = EdgeDirection.Both, scatterDirection = EdgeDirection.Both)(
// (me_id, edge) => edge.otherVertexAttr(me_id), // gather
// (a: Vid, b: Vid) => math.min(a, b), // merge
// (id, data, a: Option[Vid]) => math.min(data, a.getOrElse(Long.MaxValue)), // apply
// (me_id, edge) => (edge.vertexAttr(me_id) < edge.otherVertexAttr(me_id))
// )
} // end of connectedComponents
......
......@@ -8,7 +8,7 @@ import org.apache.spark.rdd.RDD
* message-passing API. However, unlike the original Pregel API
* the GraphX pregel API factors the sendMessage computation over
* edges, enables the message sending computation to read both
* vertex attributes, and finally contrains messages to the graph
* vertex attributes, and finally constrains messages to the graph
* structure. These changes allow for substantially more efficient
* distributed execution while also exposing greater flexibility
* for graph based computation.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment