TC

run API

API

run[VD: ClassTag, ED: ClassTag](graph: Graph[VD, ED]): Graph[Int, ED]

功能描述
 计算图网络中每个节点的三角形个数。
输入输出
1. 包名：package org.apache.spark.graphx.lib.TriangleCount
2. 类名：TriangleCount
3. 方法名：run
4. 输入：graph: Graph[VD, ED]
5. 输出：result: Graph[Int, ED]

使用样例：

TC样例：

val sparkconf = new SparkConf().setAppName("modularityCompute").setMaster(host) val sc = new SparkContext(sparkconf)
val input = sc.parallelize(Array((1,2),(1,3),(1,5),(1,4),(2,3), (3,4), (2,6),(4,5), (6, 5), (2,7),(3,7),(10,2),
(10,4),(3,8),(4,8),(3,11),(11,5),(4, 9),(9,5)))
val graph = Graph.fromEdgeTuples(input.map(f=>(f._1.toLong,f._2.toLong)), 0) val res = TriangleCount.run(graph)

样例结果

第一列为节点ID，第二列为该节点对应三角形个数。
```
4,4
11,0
1,3
6,0
3,4
7,1
9,1
8,1
10,0
5,2
2,2
```

runPreCanonicalized API

API

def runPreCanonicalized[VD: ClassTag, ED: ClassTag](graph: Graph[VD, ED]): Graph[Int, ED]

功能描述计算图网络中每个节点的三角形个数。
API描述不可处理自环和双向边，输入图无自环和双向边时可以调用此接口。
输入输出
1. 包名：package org.apache.spark.graphx.lib.TriangleCount
2. 类名：TriangleCount
3. 方法名：runPreCanonicalized
4. 输入：graph: Graph[VD, ED]
5. 输出：result: Graph[Int, ED]

使用样例

TC样例：

val input = sc.parallelize(Array((1,2),(1,3),(1,5),(1,4),(2,3), (3,4), (2,6),(4,5), (6, 5), (2,7),(3,7),(10,2),(10,4),(3,8),(4,8),(3,11),(11,5),(4, 9),(9,5)))
val graph = Graph.fromEdgeTuples(input.map(f=>(f._1.toLong,f._2.toLong)), 0)
val res = TriangleCount.runPreCanonicalized(graph)

样例结果：

第一列为节点ID，第二列为该节点对应三角形个数。
```
4,4
11,0
1,3
6,0
3,4
7,1
9,1
8,1
10,0
5,2
2,2
```

父主题： 算法API