@Override
public void reduce(NullWritable inputKey, Iterator<VLongWritable> inputValue,
OutputCollector<NullWritable, Text> output, Reporter reporter) throws IOException {
while (inputValue.hasNext()) {
long vid = inputValue.next().get();
if (vid > max)
max = vid;
}
if (this.output == null)
this.output = output;
}
DataGenerator.java 文件源码
java
阅读 23
收藏 0
点赞 0
评论 0
项目:pregelix
作者:
评论列表
文章目录