@Override
public void combine(VLongWritable vertexIndex, VLongWritable originalMessage, VLongWritable messageToCombine) {
long oldValue = messageToCombine.get();
long newValue = originalMessage.get();
if (newValue < oldValue) {
messageToCombine.set(newValue);
}
}
ConnectedComponentsVertex.java 文件源码
java
阅读 25
收藏 0
点赞 0
评论 0
项目:pregelix
作者:
评论列表
文章目录