diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-12 21:41:21 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-12 21:41:32 -0800 |
| commit | 20c509b805dbfd0ebb11d2d7bd53a4379249a86f (patch) | |
| tree | 9d32b2a814d0f54217d1bd7d1dc7f021f18caaea /graphx | |
| parent | 2216319f485ca2d00a946c4478dedc8a0e1c6053 (diff) | |
| download | spark-20c509b805dbfd0ebb11d2d7bd53a4379249a86f.tar.gz spark-20c509b805dbfd0ebb11d2d7bd53a4379249a86f.tar.bz2 spark-20c509b805dbfd0ebb11d2d7bd53a4379249a86f.zip | |
Add TriangleCount example
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala index c6b1c736dd..58da9e3aed 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala @@ -19,9 +19,8 @@ object TriangleCount { * * * @param graph a graph with `sourceId` less than `destId`. The graph must have been partitioned - * using Graph.partitionBy. - * - * @return + * using [[org.apache.spark.graphx.Graph#partitionBy]], and its edges must be in canonical + * orientation (srcId < dstId). */ def run[VD: ClassTag, ED: ClassTag](graph: Graph[VD,ED]): Graph[Int, ED] = { // Remove redundant edges |