Java 类org.apache.hadoop.hbase.io.encoding.RedundantKVGenerator 实例源码

项目：LCIndex-HBase-0.94.16 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}

项目：IRIndex 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}

项目：HBase-Research 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}

项目：hbase-0.94.8-qod 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}

项目：hbase-0.94.8-qod 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}

项目：hindex 文件：TestHFileDataBlockEncoder.java

private HFileBlock getSampleHFileBlock() {
  ByteBuffer keyValues = RedundantKVGenerator.convertKvToByteBuffer(
      generator.generateTestKeyValues(60), includesMemstoreTS);
  int size = keyValues.limit();
  ByteBuffer buf = ByteBuffer.allocate(size + HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  buf.position(HFileBlock.HEADER_SIZE_WITH_CHECKSUMS);
  keyValues.rewind();
  buf.put(keyValues);
  HFileBlock b = new HFileBlock(BlockType.DATA, size, size, -1, buf,
      HFileBlock.FILL_HEADER, 0, includesMemstoreTS, 
      HFileReaderV2.MAX_MINOR_VERSION, 0, ChecksumType.NULL.getCode(), 0);
  UNKNOWN_TABLE_AND_CF.passSchemaMetricsTo(b);
  return b;
}