import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
public static BlockStoragePolicy convert(BlockStoragePolicyProto proto) {
  List<StorageTypeProto> cList = proto.getCreationPolicy()
      .getStorageTypesList();
  StorageType[] creationTypes = convertStorageTypes(cList, cList.size());
  List<StorageTypeProto> cfList = proto.hasCreationFallbackPolicy() ? proto
      .getCreationFallbackPolicy().getStorageTypesList() : null;
  StorageType[] creationFallbackTypes = cfList == null ? StorageType
      .EMPTY_ARRAY : convertStorageTypes(cfList, cfList.size());
  List<StorageTypeProto> rfList = proto.hasReplicationFallbackPolicy() ?
      proto.getReplicationFallbackPolicy().getStorageTypesList() : null;
  StorageType[] replicationFallbackTypes = rfList == null ? StorageType
      .EMPTY_ARRAY : convertStorageTypes(rfList, rfList.size());
  return new BlockStoragePolicy((byte) proto.getPolicyId(), proto.getName(),
      creationTypes, creationFallbackTypes, replicationFallbackTypes);
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
public static List<StorageTypeProto> convertStorageTypes(
    StorageType[] types, int startIdx) {
  if (types == null) {
    return null;
  }
  final List<StorageTypeProto> protos = new ArrayList<StorageTypeProto>(
      types.length);
  for (int i = startIdx; i < types.length; ++i) {
    protos.add(convertStorageType(types[i]));
  }
  return protos; 
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
public static StorageTypeProto convertStorageType(StorageType type) {
  switch(type) {
  case DISK:
    return StorageTypeProto.DISK;
  case SSD:
    return StorageTypeProto.SSD;
  case ARCHIVE:
    return StorageTypeProto.ARCHIVE;
  case RAM_DISK:
    return StorageTypeProto.RAM_DISK;
  default:
    throw new IllegalStateException(
        "BUG: StorageType not found, type=" + type);
  }
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
public static List<StorageTypeProto> convertStorageTypes(
    StorageType[] types, int startIdx) {
  if (types == null) {
    return null;
  }
  final List<StorageTypeProto> protos = new ArrayList<>(
      types.length);
  for (int i = startIdx; i < types.length; ++i) {
    protos.add(convertStorageType(types[i]));
  }
  return protos;
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
public static BlockWithLocations convert(BlockWithLocationsProto b) {
  final List<String> datanodeUuids = b.getDatanodeUuidsList();
  final List<String> storageUuids = b.getStorageUuidsList();
  final List<StorageTypeProto> storageTypes = b.getStorageTypesList();
  BlockWithLocations blk = new BlockWithLocations(PBHelperClient.
      convert(b.getBlock()),
      datanodeUuids.toArray(new String[datanodeUuids.size()]),
      storageUuids.toArray(new String[storageUuids.size()]),
      PBHelperClient.convertStorageTypes(storageTypes, storageUuids.size()));
  if (b.hasIndices()) {
    blk = new StripedBlockWithLocations(blk, b.getIndices().toByteArray(),
        (short) b.getDataBlockNum(), b.getCellSize());
  }
  return blk;
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
private static StorageTypeProto convertStorageType(
    StorageType type) {
  switch(type) {
  case DISK:
    return StorageTypeProto.DISK;
  case SSD:
    return StorageTypeProto.SSD;
  default:
    throw new IllegalStateException(
        "BUG: StorageType not found, type=" + type);
  }
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
private static StorageType convertType(StorageTypeProto type) {
  switch(type) {
    case DISK:
      return StorageType.DISK;
    case SSD:
      return StorageType.SSD;
    default:
      throw new IllegalStateException(
          "BUG: StorageTypeProto not found, type=" + type);
  }
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto; //导入依赖的package包/类
private static StorageType[] convertStorageTypeProtos(
    List<StorageTypeProto> storageTypesList) {
  final StorageType[] storageTypes = new StorageType[storageTypesList.size()];
  for (int i = 0; i < storageTypes.length; ++i) {
    storageTypes[i] = PBHelper.convertType(storageTypesList.get(i));
  }
  return storageTypes;
}