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

项目：hadoop 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hadoop 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hadoop 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：big-c 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：big-c 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：big-c 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hadoop-plus 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hadoop-plus 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hadoop-plus 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：FlexMap 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：FlexMap 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：FlexMap 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hops 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes =
      ByteString.copyFrom(encodedKey == null ? new byte[0] : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hops 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hops 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hadoop-TCP 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hadoop-TCP 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hadoop-TCP 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hardfs 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hardfs 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hardfs 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hadoop-on-lustre2 文件：PBHelper.java

public static BlockKeyProto convert(BlockKey key) {
  byte[] encodedKey = key.getEncodedKey();
  ByteString keyBytes = ByteString.copyFrom(encodedKey == null ? 
      DFSUtil.EMPTY_BYTES : encodedKey);
  return BlockKeyProto.newBuilder().setKeyId(key.getKeyId())
      .setKeyBytes(keyBytes).setExpiryDate(key.getExpiryDate()).build();
}

项目：hadoop-on-lustre2 文件：PBHelper.java

public static BlockKey[] convertBlockKeys(List<BlockKeyProto> list) {
  BlockKey[] ret = new BlockKey[list.size()];
  int i = 0;
  for (BlockKeyProto k : list) {
    ret[i++] = convert(k);
  }
  return ret;
}

项目：hadoop-on-lustre2 文件：TestPBHelper.java

@Test
public void testConvertBlockKey() {
  BlockKey key = getBlockKey(1);
  BlockKeyProto keyProto = PBHelper.convert(key);
  BlockKey key1 = PBHelper.convert(keyProto);
  compare(key, key1);
}

项目：hadoop 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：big-c 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：hadoop-plus 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：FlexMap 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：hops 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(),
      k.getKeyBytes().toByteArray());
}

项目：hadoop-TCP 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：hardfs 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}

项目：hadoop-on-lustre2 文件：PBHelper.java

public static BlockKey convert(BlockKeyProto k) {
  return new BlockKey(k.getKeyId(), k.getExpiryDate(), k.getKeyBytes()
      .toByteArray());
}