1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand

Java 类org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand 实例源码

项目：hadoop    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  default:
    return null;
  }
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  case BlockECRecoveryCommand:
    return PBHelper.convert(proto.getBlkECRecoveryCmd());
  default:
    return null;
  }
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  default:
    return null;
  }
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  default:
    return null;
  }
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  }
  return null;
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  default:
    return null;
  }
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
    case BalancerBandwidthCommand:
      return PBHelper.convert(proto.getBalancerCmd());
    case BlockCommand:
      return PBHelper.convert(proto.getBlkCmd());
    case BlockRecoveryCommand:
      return PBHelper.convert(proto.getRecoveryCmd());
    case FinalizeCommand:
      return PBHelper.convert(proto.getFinalizeCmd());
    case KeyUpdateCommand:
      return PBHelper.convert(proto.getKeyUpdateCmd());
    case RegisterCommand:
      return REG_CMD;
  }
  return null;
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  }
  return null;
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  }
  return null;
}
项目：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    文件：PBHelper.java    
public static DatanodeCommand convert(DatanodeCommandProto proto) {
  switch (proto.getCmdType()) {
  case BalancerBandwidthCommand:
    return PBHelper.convert(proto.getBalancerCmd());
  case BlockCommand:
    return PBHelper.convert(proto.getBlkCmd());
  case BlockRecoveryCommand:
    return PBHelper.convert(proto.getRecoveryCmd());
  case FinalizeCommand:
    return PBHelper.convert(proto.getFinalizeCmd());
  case KeyUpdateCommand:
    return PBHelper.convert(proto.getKeyUpdateCmd());
  case RegisterCommand:
    return REG_CMD;
  case BlockIdCommand:
    return PBHelper.convert(proto.getBlkIdCmd());
  default:
    return null;
  }
}
项目：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);
}
项目：cumulus    文件：DatanodeDescriptor.java    
BlockRecoveryCommand getLeaseRecoveryCommand(int maxTransfers) {
  List<BlockInfoUnderConstruction> blocks = recoverBlocks.poll(maxTransfers);
  if(blocks == null)
    return null;
  BlockRecoveryCommand brCommand = new BlockRecoveryCommand(blocks.size());
  for(BlockInfoUnderConstruction b : blocks) {
    brCommand.add(new RecoveringBlock(
        b, b.getExpectedLocations(), b.getBlockRecoveryId()));
  }
  return brCommand;
}