DataGenerator.java 文件源码

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