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

项目:hadoop    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo(NodeType.NAME_NODE);
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto, NodeType.NAME_NODE);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:big-c    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo(NodeType.NAME_NODE);
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto, NodeType.NAME_NODE);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo(NodeType.NAME_NODE);
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto, NodeType.NAME_NODE);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hadoop-plus    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo();
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:FlexMap    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo(NodeType.NAME_NODE);
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto, NodeType.NAME_NODE);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hops    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).setBlockpoolID(
          info.getBlockPoolId())                //HOP added this line
      .setDEFAULTROWID(info.getDefaultRowId())
      .build();     //HOP added this line
}
项目:hops    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo();
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hadoop-TCP    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo();
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hardfs    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo();
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hadoop-on-lustre2    文件:TestPBHelper.java   
@Test
public void testConvertStoragInfo() {
  StorageInfo info = getStorageInfo(NodeType.NAME_NODE);
  StorageInfoProto infoProto = PBHelper.convert(info);
  StorageInfo info2 = PBHelper.convert(infoProto, NodeType.NAME_NODE);
  assertEquals(info.getClusterID(), info2.getClusterID());
  assertEquals(info.getCTime(), info2.getCTime());
  assertEquals(info.getLayoutVersion(), info2.getLayoutVersion());
  assertEquals(info.getNamespaceID(), info2.getNamespaceID());
}
项目:hadoop    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hadoop    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info, NodeType type) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), type);
}
项目:hadoop    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion(), info.getCapabilities());
}
项目:big-c    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:big-c    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info, NodeType type) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), type);
}
项目:big-c    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion(), info.getCapabilities());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info, NodeType type) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), type);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:hadoop-plus    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hadoop-plus    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime());
}
项目:hadoop-plus    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:FlexMap    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:FlexMap    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info, NodeType type) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), type);
}
项目:FlexMap    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:hops    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), info.getBlockpoolID());
}
项目:hops    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:hadoop-TCP    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hadoop-TCP    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime());
}
项目:hadoop-TCP    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:hardfs    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hardfs    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime());
}
项目:hardfs    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}
项目:hadoop-on-lustre2    文件:PBHelper.java   
public static StorageInfoProto convert(StorageInfo info) {
  return StorageInfoProto.newBuilder().setClusterID(info.getClusterID())
      .setCTime(info.getCTime()).setLayoutVersion(info.getLayoutVersion())
      .setNamespceID(info.getNamespaceID()).build();
}
项目:hadoop-on-lustre2    文件:PBHelper.java   
public static StorageInfo convert(StorageInfoProto info, NodeType type) {
  return new StorageInfo(info.getLayoutVersion(), info.getNamespceID(),
      info.getClusterID(), info.getCTime(), type);
}
项目:hadoop-on-lustre2    文件:PBHelper.java   
public static NamespaceInfo convert(NamespaceInfoProto info) {
  StorageInfoProto storage = info.getStorageInfo();
  return new NamespaceInfo(storage.getNamespceID(), storage.getClusterID(),
      info.getBlockPoolID(), storage.getCTime(), info.getBuildVersion(),
      info.getSoftwareVersion());
}