我正在研究一个图,我想使用pregel在图上进行并行计算。该图的结构类似于以下结构:
(1,(5,0.2))
(2,(8,0.8))
...
键是node id,括号内的第一个数字是node的标签,括号内的第二个数字是score。我想将每个节点属性发送给它的邻居,并将它们收集到一个列表中。有人能帮忙写代码的主要结构吗?我的意思是只指定我应该在 Vertexprogram
, mergeprogram
以及 sendmessage
功能??
我正在研究一个图,我想使用pregel在图上进行并行计算。该图的结构类似于以下结构:
(1,(5,0.2))
(2,(8,0.8))
...
键是node id,括号内的第一个数字是node的标签,括号内的第二个数字是score。我想将每个节点属性发送给它的邻居,并将它们收集到一个列表中。有人能帮忙写代码的主要结构吗?我的意思是只指定我应该在 Vertexprogram
, mergeprogram
以及 sendmessage
功能??
暂无答案!
目前还没有任何答案,快来回答吧!