@Override
public void map(LongWritable id, Text inputValue, OutputCollector<NullWritable, VLongWritable> output,
Reporter reporter) throws IOException {
String[] vertices = inputValue.toString().split(" ");
long max = Long.parseLong(vertices[0]);
for (int i = 1; i < vertices.length; i++) {
long vid = Long.parseLong(vertices[i]);
if (vid > max)
max = vid;
}
value.set(max);
output.collect(key, value);
}
DataGenerator.java 文件源码
java
阅读 24
收藏 0
点赞 0
评论 0
项目:pregelix
作者:
评论列表
文章目录