EN
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

MCE

  • API
    run[T: ClassTag](graph: RDD[(T, T)], minK: Int, maxDegree: Int, repartition: Int): (RDD[(Int, T)], RDD[(Int, String)])
  • 功能描述

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

  • API描述
    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