DataGenerator.java 文件源码

@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;

}