Java 类org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto 实例源码

项目:hadoop    文件:PBHelper.java   
public static StorageReportProto convert(StorageReport r) {
  StorageReportProto.Builder builder = StorageReportProto.newBuilder()
      .setBlockPoolUsed(r.getBlockPoolUsed()).setCapacity(r.getCapacity())
      .setDfsUsed(r.getDfsUsed()).setRemaining(r.getRemaining())
      .setStorageUuid(r.getStorage().getStorageID())
      .setStorage(convert(r.getStorage()));
  return builder.build();
}
项目:hadoop    文件:PBHelper.java   
public static StorageReport convert(StorageReportProto p) {
  return new StorageReport(
      p.hasStorage() ?
          convert(p.getStorage()) :
          new DatanodeStorage(p.getStorageUuid()),
      p.getFailed(), p.getCapacity(), p.getDfsUsed(), p.getRemaining(),
      p.getBlockPoolUsed());
}
项目:hadoop    文件:PBHelper.java   
public static StorageReport[] convertStorageReports(
    List<StorageReportProto> list) {
  final StorageReport[] report = new StorageReport[list.size()];
  for (int i = 0; i < report.length; i++) {
    report[i] = convert(list.get(i));
  }
  return report;
}
项目:hadoop    文件:PBHelper.java   
public static List<StorageReportProto> convertStorageReports(StorageReport[] storages) {
  final List<StorageReportProto> protos = new ArrayList<StorageReportProto>(
      storages.length);
  for(int i = 0; i < storages.length; i++) {
    protos.add(convert(storages[i]));
  }
  return protos;
}
项目:aliyun-oss-hadoop-fs    文件:PBHelperClient.java   
public static StorageReport[] convertStorageReports(
    List<StorageReportProto> list) {
  final StorageReport[] report = new StorageReport[list.size()];
  for (int i = 0; i < report.length; i++) {
    report[i] = convert(list.get(i));
  }
  return report;
}
项目:aliyun-oss-hadoop-fs    文件:PBHelperClient.java   
public static StorageReport convert(StorageReportProto p) {
  return new StorageReport(
      p.hasStorage() ?
          convert(p.getStorage()) :
          new DatanodeStorage(p.getStorageUuid()),
      p.getFailed(), p.getCapacity(), p.getDfsUsed(), p.getRemaining(),
      p.getBlockPoolUsed());
}
项目:aliyun-oss-hadoop-fs    文件:PBHelperClient.java   
public static StorageReportProto convert(StorageReport r) {
  StorageReportProto.Builder builder = StorageReportProto.newBuilder()
      .setBlockPoolUsed(r.getBlockPoolUsed()).setCapacity(r.getCapacity())
      .setDfsUsed(r.getDfsUsed()).setRemaining(r.getRemaining())
      .setStorageUuid(r.getStorage().getStorageID())
      .setStorage(convert(r.getStorage()));
  return builder.build();
}
项目:aliyun-oss-hadoop-fs    文件:PBHelperClient.java   
public static List<StorageReportProto> convertStorageReports(
    StorageReport[] storages) {
  final List<StorageReportProto> protos = new ArrayList<>(storages.length);
  for (StorageReport storage : storages) {
    protos.add(convert(storage));
  }
  return protos;
}
项目:big-c    文件:PBHelper.java   
public static StorageReportProto convert(StorageReport r) {
  StorageReportProto.Builder builder = StorageReportProto.newBuilder()
      .setBlockPoolUsed(r.getBlockPoolUsed()).setCapacity(r.getCapacity())
      .setDfsUsed(r.getDfsUsed()).setRemaining(r.getRemaining())
      .setStorageUuid(r.getStorage().getStorageID())
      .setStorage(convert(r.getStorage()));
  return builder.build();
}
项目:big-c    文件:PBHelper.java   
public static StorageReport convert(StorageReportProto p) {
  return new StorageReport(
      p.hasStorage() ?
          convert(p.getStorage()) :
          new DatanodeStorage(p.getStorageUuid()),
      p.getFailed(), p.getCapacity(), p.getDfsUsed(), p.getRemaining(),
      p.getBlockPoolUsed());
}
项目:big-c    文件:PBHelper.java   
public static StorageReport[] convertStorageReports(
    List<StorageReportProto> list) {
  final StorageReport[] report = new StorageReport[list.size()];
  for (int i = 0; i < report.length; i++) {
    report[i] = convert(list.get(i));
  }
  return report;
}
项目:big-c    文件:PBHelper.java   
public static List<StorageReportProto> convertStorageReports(StorageReport[] storages) {
  final List<StorageReportProto> protos = new ArrayList<StorageReportProto>(
      storages.length);
  for(int i = 0; i < storages.length; i++) {
    protos.add(convert(storages[i]));
  }
  return protos;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static StorageReportProto convert(StorageReport r) {
  StorageReportProto.Builder builder = StorageReportProto.newBuilder()
      .setBlockPoolUsed(r.getBlockPoolUsed()).setCapacity(r.getCapacity())
      .setDfsUsed(r.getDfsUsed()).setRemaining(r.getRemaining())
      .setStorageUuid(r.getStorage().getStorageID())
      .setStorage(convert(r.getStorage()));
  return builder.build();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static StorageReport convert(StorageReportProto p) {
  return new StorageReport(
      p.hasStorage() ?
          convert(p.getStorage()) :
          new DatanodeStorage(p.getStorageUuid()),
      p.getFailed(), p.getCapacity(), p.getDfsUsed(), p.getRemaining(),
      p.getBlockPoolUsed());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static StorageReport[] convertStorageReports(
    List<StorageReportProto> list) {
  final StorageReport[] report = new StorageReport[list.size()];
  for (int i = 0; i < report.length; i++) {
    report[i] = convert(list.get(i));
  }
  return report;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static List<StorageReportProto> convertStorageReports(StorageReport[] storages) {
  final List<StorageReportProto> protos = new ArrayList<StorageReportProto>(
      storages.length);
  for(int i = 0; i < storages.length; i++) {
    protos.add(convert(storages[i]));
  }
  return protos;
}
项目:FlexMap    文件:PBHelper.java   
public static StorageReportProto convert(StorageReport r) {
  StorageReportProto.Builder builder = StorageReportProto.newBuilder()
      .setBlockPoolUsed(r.getBlockPoolUsed()).setCapacity(r.getCapacity())
      .setDfsUsed(r.getDfsUsed()).setRemaining(r.getRemaining())
      .setStorageUuid(r.getStorage().getStorageID())
      .setStorage(convert(r.getStorage()));
  return builder.build();
}
项目:FlexMap    文件:PBHelper.java   
public static StorageReport convert(StorageReportProto p) {
  return new StorageReport(
      p.hasStorage() ?
          convert(p.getStorage()) :
          new DatanodeStorage(p.getStorageUuid()),
      p.getFailed(), p.getCapacity(), p.getDfsUsed(), p.getRemaining(),
      p.getBlockPoolUsed());
}
项目:FlexMap    文件:PBHelper.java   
public static StorageReport[] convertStorageReports(
    List<StorageReportProto> list) {
  final StorageReport[] report = new StorageReport[list.size()];
  for (int i = 0; i < report.length; i++) {
    report[i] = convert(list.get(i));
  }
  return report;
}
项目:FlexMap    文件:PBHelper.java   
public static List<StorageReportProto> convertStorageReports(StorageReport[] storages) {
  final List<StorageReportProto> protos = new ArrayList<StorageReportProto>(
      storages.length);
  for(int i = 0; i < storages.length; i++) {
    protos.add(convert(storages[i]));
  }
  return protos;
}