TC

run API

• API

  1	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

  1	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样例：

  1 2 3

  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