如何在spark graphx中编写pregel代码的主要结构?

kr98yfug  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(214)

我正在研究一个图,我想使用pregel在图上进行并行计算。该图的结构类似于以下结构:

(1,(5,0.2))
(2,(8,0.8))
...

键是node id,括号内的第一个数字是node的标签,括号内的第二个数字是score。我想将每个节点属性发送给它的邻居,并将它们收集到一个列表中。有人能帮忙写代码的主要结构吗?我的意思是只指定我应该在 Vertexprogram , mergeprogram 以及 sendmessage 功能??

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题