1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CheckpointSignatureProto

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

项目：hadoop    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hadoop    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(
      getStorageInfo(NodeType.NAME_NODE), "bpid", 100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：big-c    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：big-c    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(
      getStorageInfo(NodeType.NAME_NODE), "bpid", 100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(
      getStorageInfo(NodeType.NAME_NODE), "bpid", 100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hadoop-plus    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hadoop-plus    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(getStorageInfo(), "bpid",
      100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：FlexMap    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：FlexMap    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(
      getStorageInfo(NodeType.NAME_NODE), "bpid", 100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hadoop-TCP    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hadoop-TCP    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(getStorageInfo(), "bpid",
      100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hardfs    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hardfs    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(getStorageInfo(), "bpid",
      100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static CheckpointSignatureProto convert(CheckpointSignature s) {
  return CheckpointSignatureProto.newBuilder()
      .setBlockPoolId(s.getBlockpoolID())
      .setCurSegmentTxId(s.getCurSegmentTxId())
      .setMostRecentCheckpointTxId(s.getMostRecentCheckpointTxId())
      .setStorageInfo(PBHelper.convert((StorageInfo) s)).build();
}
项目：hadoop-on-lustre2    文件：TestPBHelper.java    
@Test
public void testConvertCheckpointSignature() {
  CheckpointSignature s = new CheckpointSignature(
      getStorageInfo(NodeType.NAME_NODE), "bpid", 100, 1);
  CheckpointSignatureProto sProto = PBHelper.convert(s);
  CheckpointSignature s1 = PBHelper.convert(sProto);
  assertEquals(s.getBlockpoolID(), s1.getBlockpoolID());
  assertEquals(s.getClusterID(), s1.getClusterID());
  assertEquals(s.getCTime(), s1.getCTime());
  assertEquals(s.getCurSegmentTxId(), s1.getCurSegmentTxId());
  assertEquals(s.getLayoutVersion(), s1.getLayoutVersion());
  assertEquals(s.getMostRecentCheckpointTxId(),
      s1.getMostRecentCheckpointTxId());
  assertEquals(s.getNamespaceID(), s1.getNamespaceID());
}
项目：hadoop    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  StorageInfo si = PBHelper.convert(s.getStorageInfo(), NodeType.NAME_NODE);
  return new CheckpointSignature(si, s.getBlockPoolId(),
      s.getMostRecentCheckpointTxId(), s.getCurSegmentTxId());
}
项目：big-c    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  StorageInfo si = PBHelper.convert(s.getStorageInfo(), NodeType.NAME_NODE);
  return new CheckpointSignature(si, s.getBlockPoolId(),
      s.getMostRecentCheckpointTxId(), s.getCurSegmentTxId());
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  StorageInfo si = PBHelper.convert(s.getStorageInfo(), NodeType.NAME_NODE);
  return new CheckpointSignature(si, s.getBlockPoolId(),
      s.getMostRecentCheckpointTxId(), s.getCurSegmentTxId());
}
项目：hadoop-plus    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  return new CheckpointSignature(PBHelper.convert(s.getStorageInfo()),
      s.getBlockPoolId(), s.getMostRecentCheckpointTxId(),
      s.getCurSegmentTxId());
}
项目：FlexMap    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  StorageInfo si = PBHelper.convert(s.getStorageInfo(), NodeType.NAME_NODE);
  return new CheckpointSignature(si, s.getBlockPoolId(),
      s.getMostRecentCheckpointTxId(), s.getCurSegmentTxId());
}
项目：hadoop-TCP    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  return new CheckpointSignature(PBHelper.convert(s.getStorageInfo()),
      s.getBlockPoolId(), s.getMostRecentCheckpointTxId(),
      s.getCurSegmentTxId());
}
项目：hardfs    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  return new CheckpointSignature(PBHelper.convert(s.getStorageInfo()),
      s.getBlockPoolId(), s.getMostRecentCheckpointTxId(),
      s.getCurSegmentTxId());
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static CheckpointSignature convert(CheckpointSignatureProto s) {
  StorageInfo si = PBHelper.convert(s.getStorageInfo(), NodeType.NAME_NODE);
  return new CheckpointSignature(si, s.getBlockPoolId(),
      s.getMostRecentCheckpointTxId(), s.getCurSegmentTxId());
}