From 20c509b805dbfd0ebb11d2d7bd53a4379249a86f Mon Sep 17 00:00:00 2001 From: Ankur Dave Date: Sun, 12 Jan 2014 21:41:21 -0800 Subject: Add TriangleCount example --- .../src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'graphx') 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 -- cgit v1.2.3