1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto

Java 类org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto 实例源码

项目：hadoop    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：aliyun-oss-hadoop-fs    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：big-c    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hadoop-plus    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：FlexMap    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hops    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[]{di1, di2};

  List<RecoveringBlock> blks = ImmutableList
      .of(new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
          new RecoveringBlock(getExtendedBlock(2), dnInfo, 3));

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks =
      Lists.newArrayList(cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hadoop-TCP    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hardfs    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hadoop-on-lustre2    文件：TestPBHelper.java    
@Test
public void testConvertBlockRecoveryCommand() {
  DatanodeInfo di1 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo di2 = DFSTestUtil.getLocalDatanodeInfo();
  DatanodeInfo[] dnInfo = new DatanodeInfo[] { di1, di2 };

  List<RecoveringBlock> blks = ImmutableList.of(
    new RecoveringBlock(getExtendedBlock(1), dnInfo, 3),
    new RecoveringBlock(getExtendedBlock(2), dnInfo, 3)
  );

  BlockRecoveryCommand cmd = new BlockRecoveryCommand(blks);
  BlockRecoveryCommandProto proto = PBHelper.convert(cmd);
  assertEquals(1, proto.getBlocks(0).getBlock().getB().getBlockId());
  assertEquals(2, proto.getBlocks(1).getBlock().getB().getBlockId());

  BlockRecoveryCommand cmd2 = PBHelper.convert(proto);

  List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
      cmd2.getRecoveringBlocks());
  assertEquals(blks.get(0).getBlock(), cmd2Blks.get(0).getBlock());
  assertEquals(blks.get(1).getBlock(), cmd2Blks.get(1).getBlock());
  assertEquals(Joiner.on(",").join(blks), Joiner.on(",").join(cmd2Blks));
  assertEquals(cmd.toString(), cmd2.toString());
}
项目：hadoop    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hadoop    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：aliyun-oss-hadoop-fs    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：aliyun-oss-hadoop-fs    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：big-c    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：big-c    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hadoop-plus    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hadoop-plus    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：FlexMap    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：FlexMap    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hops    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder =
      BlockRecoveryCommandProto.newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hops    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks =
      new ArrayList<>(list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hadoop-TCP    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hadoop-TCP    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hardfs    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hardfs    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd) {
  BlockRecoveryCommandProto.Builder builder = BlockRecoveryCommandProto
      .newBuilder();
  for (RecoveringBlock b : cmd.getRecoveringBlocks()) {
    builder.addBlocks(PBHelper.convert(b));
  }
  return builder.build();
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static BlockRecoveryCommand convert(
    BlockRecoveryCommandProto recoveryCmd) {
  List<RecoveringBlockProto> list = recoveryCmd.getBlocksList();
  List<RecoveringBlock> recoveringBlocks = new ArrayList<RecoveringBlock>(
      list.size());

  for (RecoveringBlockProto rbp : list) {
    recoveringBlocks.add(PBHelper.convert(rbp));
  }
  return new BlockRecoveryCommand(recoveringBlocks);
}