并行 SimRank 算法 使用 Delta-Simrank 算法 ( )。 通过将每个 SimRank 迭代作为 Map 和两个 Reduce 任务的三元组执行,利用 Spark 的 GraphX 框架和内存中/迭代计算优势,而不是 YARN 等其他 MapReduce 框架。 Map1 : 发出键值对,其中每个键是与之前迭代中更新分数的顶点相邻的一对顶点id,该值是SimRank的边际增加(deltas的精确计算方法参考delta-simrank算法)。 Reduce1 :按键聚合增量值。 Reduce2 :将 delta 与上一次迭代 SimRank 分数相加,以获得当前迭代的 SimRank 分数。 先决条件:GraphX 包。 参数说明 数据源 - graphEdgelistPath :传递给 GraphX 图形加载器的边列表。 为了有效地存储中间 SimRank
2022-02-27 09:55:33 122KB Scala
1
simrank算法Java实现,包含实现算法引用的两个jar包:fastutil-6.5.15.jar、webgraph-3.4.0.jar,自行导入
2021-12-10 19:28:16 14.64MB simrank
1
simrank 算法实现 及 相应文件 社会计算课程实践
2019-12-21 19:50:43 2KB simrank
1