diff options
| author | Sasaki Toru <sasakitoa@nttdata.co.jp> | 2015-04-07 01:55:32 -0700 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2015-04-07 01:55:32 -0700 |
| commit | ae980eb41c00b5f1f64c650f267b884e864693f0 (patch) | |
| tree | d65ab6c91ec9961b3f35d0bf7467d563364f2370 /graphx | |
| parent | 6f0d55d76f758d217fd18ffa0ccf273d7ab0377b (diff) | |
| download | spark-ae980eb41c00b5f1f64c650f267b884e864693f0.tar.gz spark-ae980eb41c00b5f1f64c650f267b884e864693f0.tar.bz2 spark-ae980eb41c00b5f1f64c650f267b884e864693f0.zip | |
[SPARK-6736][GraphX][Doc]Example of Graph#aggregateMessages has error
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
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/Graph.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala b/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala index 8494d06b1c..36dc7b0f86 100644 --- 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 |