鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

MCE

run API

  • API
    1
    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样例:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    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