Package org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto

Examples of org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto.Builder


    }
  }
 
  public static LocatedBlockProto convert(LocatedBlock b) {
    if (b == null) return null;
    Builder builder = LocatedBlockProto.newBuilder();
    DatanodeInfo[] locs = b.getLocations();
    for (int i = 0; i < locs.length; i++) {
      builder.addLocs(i, PBHelper.convert(locs[i]));
    }
    return builder.setB(PBHelper.convert(b.getBlock()))
        .setBlockToken(PBHelper.convert(b.getBlockToken()))
        .setCorrupt(b.isCorrupt()).setOffset(b.getStartOffset()).build();
  }
View Full Code Here

TOP

Related Classes of org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto.Builder

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.