HadoopInputSplit.java 文件源码

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

项目:vs.msc.ws14 作者:
@Override
public void read(DataInputView in) throws IOException {
    this.splitNumber=in.readInt();
    String className = in.readUTF();

    if(this.mapreduceInputSplit == null) {
        try {
            Class<? extends org.apache.hadoop.io.Writable> inputSplit = 
                    Class.forName(className).asSubclass(org.apache.hadoop.io.Writable.class);
            this.mapreduceInputSplit = (org.apache.hadoop.mapreduce.InputSplit) WritableFactories.newInstance(inputSplit);
        } catch (Exception e) {
            throw new RuntimeException("Unable to create InputSplit", e);
        }
    }
    ((Writable)this.mapreduceInputSplit).readFields(in);
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号