DataGenerator.java 文件源码

java
阅读 25 收藏 0 点赞 0 评论 0

项目:pregelix 作者:
@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);
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号