MCE

run[T: ClassTag](graph: RDD[(T, T)], minK: Int, maxDegree: Int, repartition: Int): (RDD[(Int, T)], RDD[(Int, String)])

根据指定过滤条件计算关系网络中极大团信息。

1. 包名：package org.apache.spark.graphx.lib
2. 类名：MaximalCliqueEnumeration
3. 方法名：run
4. 参数：如表1所示。

   表1 参数详情

   参数名称	参数含义	取值类型
   graph	图边数据	RDD[(T, T)]
   minK	小的极大团节点规模	Int如3等
   maxDegree	节点最大度数（指和该节点相关联的边的条数）	Int如2000等
   repartition	计算时分区个数	Int如100等
   T	节点类型	String或Int或Long

5. 输出：

   RDD[(Int , T)]——节点映射关系：新节点ID 原节点ID

   RDD[(Int, String)]——节点所属极大团：新节点ID 极大团编号

MCE样例：

val conf = new SparkConf().setAppName("Maximal Clique Detection")
val sc = new SparkContext(conf)
val inputData = Array(
("1", "2"),
("1", "3"),
("2", "3"),
("1", "4"))
val inputDataRdd = sc.parallelize(inputData)
MaximalCliqueEnumeration.run(inputDataRdd, 3, 2000, 1)

节点映射结果：
0,4
1,2
2,3
3,1
极大团结果：
1,c1
2,c1
3,c1