[SPARK-6736][GraphX][Doc]Example of Graph#aggregateMessages has error

sasakitoa · ankurdave · commit ae980eb41c00 · 2015-04-07T01:55:32.000-07:00
Example of Graph#aggregateMessages has error. Since aggregateMessages is a method of Graph, It should be written "rawGraph.aggregateMessages" Author: Sasaki Toru <sasakitoa@nttdata.co.jp> Closes #5388 from sasakitoa/aggregateMessagesExample and squashes the following commits: b1d631b [Sasaki Toru] Example of Graph#aggregateMessages has error
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala b/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala
@@ -409,7 +409,7 @@ abstract class Graph[VD: ClassTag, ED: ClassTag] protected () extends Serializab
    * {{{
    * val rawGraph: Graph[_, _] = Graph.textFile("twittergraph")
    * val inDeg: RDD[(VertexId, Int)] =
-   *   aggregateMessages[Int](ctx => ctx.sendToDst(1), _ + _)
+   *   rawGraph.aggregateMessages[Int](ctx => ctx.sendToDst(1), _ + _)
    * }}}
    *
    * @note By expressing computation at the edge level we achieve

Original file line number	Diff line number	Diff line change
`@@ -409,7 +409,7 @@ abstract class Graph[VD: ClassTag, ED: ClassTag] protected () extends Serializab`
`409`	`409`	`* {{{`
`410`	`410`	`* val rawGraph: Graph[_, _] = Graph.textFile("twittergraph")`
`411`	`411`	`* val inDeg: RDD[(VertexId, Int)] =`
`412`		`- * aggregateMessages[Int](ctx => ctx.sendToDst(1), _ + _)`
	`412`	`+ * rawGraph.aggregateMessages[Int](ctx => ctx.sendToDst(1), _ + _)`
`413`	`413`	`* }}}`
`414`	`414`	`*`
`415`	`415`	`* @note By expressing computation at the edge level we achieve`