org.apache.hadoop.hbase.io.encoding

Class TestDataBlockEncoders

java.lang.Object

org.apache.hadoop.hbase.io.encoding.TestDataBlockEncoders

public class TestDataBlockEncoders
extends Object

Test all of the data block encoding algorithms for correctness. Most of the class generate data which will test different branches in code.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static int	ENCODED_DATA_OFFSET
private RedundantKVGenerator	generator
(package private) static byte[]	HFILEBLOCK_DUMMY_HEADER
private boolean	includesMemstoreTS
private boolean	includesTags
private static org.slf4j.Logger	LOG
private static int	NUM_RANDOM_SEEKS
private static int	NUMBER_OF_KV
private boolean	useOffheapData

Constructor Summary

Constructors

Constructor and Description
TestDataBlockEncoders(boolean includesMemstoreTS, boolean includesTag, boolean useOffheapData)

Method Summary

Modifier and Type	Method and Description
private void	checkSeekingConsistency(List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoder.EncodedSeeker> encodedSeekers, boolean seekBefore, org.apache.hadoop.hbase.Cell keyValue)
(package private) static ByteBuffer	encodeKeyValues(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding, List<org.apache.hadoop.hbase.KeyValue> kvs, org.apache.hadoop.hbase.io.encoding.HFileBlockEncodingContext encodingContext, boolean useOffheapData)
private org.apache.hadoop.hbase.io.encoding.HFileBlockEncodingContext	getEncodingContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.io.compress.Compression.Algorithm algo, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding)
static Collection<Object[]>	parameters()
private void	testAlgorithm(byte[] encodedData, ByteBuffer unencodedDataBuf, org.apache.hadoop.hbase.io.encoding.DataBlockEncoder encoder)
void	testEmptyKeyValues() Test data block encoding of empty KeyValue.
private void	testEncodersOnDataset(List<org.apache.hadoop.hbase.KeyValue> kvList, boolean includesMemstoreTS, boolean includesTags)
void	testExecutionOnSample() Test whether compression -> decompression gives the consistent results on pseudorandom sample.
void	testFirstKeyInBlockOnSample() Test whether the decompression of first key is implemented correctly.
void	testNegativeTimestamps() Test KeyValues with negative timestamp.
void	testNextOnSample()
void	testRowIndexWithTagsButNoTagsInCell()
void	testSeekingOnSample() Test seeking while file is encoded.
void	testZeroByte()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

NUMBER_OF_KV

private static int NUMBER_OF_KV

NUM_RANDOM_SEEKS

private static int NUM_RANDOM_SEEKS

ENCODED_DATA_OFFSET

private static int ENCODED_DATA_OFFSET

HFILEBLOCK_DUMMY_HEADER

static final byte[] HFILEBLOCK_DUMMY_HEADER

conf

private final org.apache.hadoop.conf.Configuration conf

generator

private final RedundantKVGenerator generator

includesMemstoreTS

private final boolean includesMemstoreTS

includesTags

private final boolean includesTags

useOffheapData

private final boolean useOffheapData

Constructor Detail

TestDataBlockEncoders

public TestDataBlockEncoders(boolean includesMemstoreTS,
                             boolean includesTag,
                             boolean useOffheapData)

Method Detail

parameters

public static Collection<Object[]> parameters()

getEncodingContext

private org.apache.hadoop.hbase.io.encoding.HFileBlockEncodingContext getEncodingContext(org.apache.hadoop.conf.Configuration conf,
                                                                                         org.apache.hadoop.hbase.io.compress.Compression.Algorithm algo,
                                                                                         org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding)

testEmptyKeyValues

public void testEmptyKeyValues()
                        throws IOException

Test data block encoding of empty KeyValue. n * On test failure.

Throws:

IOException

testNegativeTimestamps

public void testNegativeTimestamps()
                            throws IOException

Test KeyValues with negative timestamp. n * On test failure.

Throws:

IOException

testExecutionOnSample

public void testExecutionOnSample()
                           throws IOException

Test whether compression -> decompression gives the consistent results on pseudorandom sample.

Throws:

IOException - On test failure.

testSeekingOnSample

public void testSeekingOnSample()
                         throws IOException

Test seeking while file is encoded.

Throws:

IOException

encodeKeyValues

static ByteBuffer encodeKeyValues(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding,
                                  List<org.apache.hadoop.hbase.KeyValue> kvs,
                                  org.apache.hadoop.hbase.io.encoding.HFileBlockEncodingContext encodingContext,
                                  boolean useOffheapData)
                           throws IOException

Throws:

IOException

testNextOnSample

public void testNextOnSample()
                      throws IOException

Throws:

IOException

testFirstKeyInBlockOnSample

public void testFirstKeyInBlockOnSample()
                                 throws IOException

Test whether the decompression of first key is implemented correctly. n

Throws:

IOException

testRowIndexWithTagsButNoTagsInCell

public void testRowIndexWithTagsButNoTagsInCell()
                                         throws IOException

Throws:

IOException

checkSeekingConsistency

private void checkSeekingConsistency(List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoder.EncodedSeeker> encodedSeekers,
                                     boolean seekBefore,
                                     org.apache.hadoop.hbase.Cell keyValue)

testEncodersOnDataset

private void testEncodersOnDataset(List<org.apache.hadoop.hbase.KeyValue> kvList,
                                   boolean includesMemstoreTS,
                                   boolean includesTags)
                            throws IOException

Throws:

IOException

testZeroByte

public void testZeroByte()
                  throws IOException

Throws:

IOException

testAlgorithm

private void testAlgorithm(byte[] encodedData,
                           ByteBuffer unencodedDataBuf,
                           org.apache.hadoop.hbase.io.encoding.DataBlockEncoder encoder)
                    throws IOException

Throws:

IOException