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());
}