diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 14:54:33 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 14:54:33 -0800 |
| commit | 15ca89b11edbb2800efc992d6cf4eba787a00873 (patch) | |
| tree | eab6a4ba4aca5d9794e362fd2384808f24b73948 /docs/graphx-programming-guide.md | |
| parent | 9fe88627b5716c6893a6d034fefcf530a6c470fa (diff) | |
| download | spark-15ca89b11edbb2800efc992d6cf4eba787a00873.tar.gz spark-15ca89b11edbb2800efc992d6cf4eba787a00873.tar.bz2 spark-15ca89b11edbb2800efc992d6cf4eba787a00873.zip | |
Fix mapReduceTriplets links in doc
Diffstat (limited to 'docs/graphx-programming-guide.md')
| -rw-r--r-- | docs/graphx-programming-guide.md | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/docs/graphx-programming-guide.md b/docs/graphx-programming-guide.md index 2697b2def7..1832ded888 100644 --- a/docs/graphx-programming-guide.md +++ b/docs/graphx-programming-guide.md @@ -443,10 +443,10 @@ PageRank Value, shortest path to the source, and smallest reachable vertex id). ### Map Reduce Triplets (mapReduceTriplets) <a name="mrTriplets"></a> -[Graph.mapReduceTriplets]: api/graphx/index.html#mapReduceTriplets[A](mapFunc:org.apache.spark.graphx.EdgeTriplet[VD,ED]=>Iterator[(org.apache.spark.graphx.VertexID,A)],reduceFunc:(A,A)=>A,activeSetOpt:Option[(org.apache.spark.graphx.VertexRDD[_],org.apache.spark.graphx.EdgeDirection)])(implicitevidence$10:scala.reflect.ClassTag[A]):org.apache.spark.graphx.VertexRDD[A] +[Graph.mapReduceTriplets]: api/graphx/index.html#org.apache.spark.graphx.Graph@mapReduceTriplets[A](mapFunc:org.apache.spark.graphx.EdgeTriplet[VD,ED]=>Iterator[(org.apache.spark.graphx.VertexID,A)],reduceFunc:(A,A)=>A,activeSetOpt:Option[(org.apache.spark.graphx.VertexRDD[_],org.apache.spark.graphx.EdgeDirection)])(implicitevidence$10:scala.reflect.ClassTag[A]):org.apache.spark.graphx.VertexRDD[A] -These core (heavily optimized) aggregation primitive in GraphX is the -(`mapReduceTriplets`)[Graph.mapReduceTriplets] operator: +The core (heavily optimized) aggregation primitive in GraphX is the +[`mapReduceTriplets`][Graph.mapReduceTriplets] operator: {% highlight scala %} def mapReduceTriplets[A]( @@ -455,7 +455,7 @@ def mapReduceTriplets[A]( : VertexRDD[A] {% endhighlight %} -The (`mapReduceTriplets`)[Graph.mapReduceTriplets] operator takes a user defined map function which +The [`mapReduceTriplets`][Graph.mapReduceTriplets] operator takes a user defined map function which is applied to each triplet and can yield *messages* destined to either (none or both) vertices in the triplet. We currently only support messages destined to the source or destination vertex of the triplet to enable optimized preaggregation. The user defined `reduce` function combines the |