文件名称：PIO-Parallel-Simrank-Engine
文件大小：122KB
文件格式：ZIP
更新时间：2024-07-17 01:00:52
Scala
并行 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 分
【文件预览】：
PIO-Parallel-Simrank-Engine-master
----data()
--------send_query.py(193B)
--------edge_list_small.txt(89B)
--------import_eventserver.py(1KB)
--------sample_not_train_data.txt(22B)
----project()
--------project()
--------assembly.sbt(57B)
--------target()
----src()
--------.DS_Store(6KB)
--------main()
----README.md(2KB)
----engine.json(470B)
----manifest.json(207B)
----build.sbt(372B)