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