org.apache.hadoop.hbase.io.encoding

Class TestChangingEncoding

java.lang.Object

org.apache.hadoop.hbase.io.encoding.TestChangingEncoding

public class TestChangingEncoding
extends Object

Tests changing data block encoding settings of a column family.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static String	CF
(package private) static byte[]	CF_BYTES
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf
private static List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoding>	ENCODINGS_TO_ITERATE
private org.apache.hadoop.hbase.HColumnDescriptor	hcd
private static org.slf4j.Logger	LOG
private static int	NUM_COLS_PER_ROW
private static int	NUM_ROWS_PER_BATCH
private int	numBatchesWritten A zero-based index of the current batch of test data being written
private org.apache.hadoop.hbase.TableName	tableName
private static HBaseTestingUtility	TEST_UTIL
private static int	TIMEOUT_MS

Constructor Summary

Constructors

Constructor and Description
TestChangingEncoding()

Method Summary

Modifier and Type	Method and Description
private void	compactAndWait()
private static List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoding>	createEncodingsToIterate()
private static byte[]	getQualifier(int j)
private static byte[]	getRowKey(int batchId, int i)
private static byte[]	getValue(int batchId, int i, int j)
private void	prepareTest(String testId)
private void	setEncodingConf(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding, boolean onlineChange)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testChangingEncoding()
void	testChangingEncodingWithCompaction()
void	testCrazyRandomChanges()
private void	verifyAllData()
(package private) static void	verifyTestDataBatch(org.apache.hadoop.hbase.TableName tableName, int batchId)
private void	writeSomeNewData()
(package private) static void	writeTestDataBatch(org.apache.hadoop.hbase.TableName tableName, int batchId)

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

CF

static final String CF

See Also:

Constant Field Values

CF_BYTES

static final byte[] CF_BYTES

NUM_ROWS_PER_BATCH

private static final int NUM_ROWS_PER_BATCH

See Also:

Constant Field Values

NUM_COLS_PER_ROW

private static final int NUM_COLS_PER_ROW

See Also:

Constant Field Values

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

conf

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

TIMEOUT_MS

private static final int TIMEOUT_MS

See Also:

Constant Field Values

hcd

private org.apache.hadoop.hbase.HColumnDescriptor hcd

tableName

private org.apache.hadoop.hbase.TableName tableName

ENCODINGS_TO_ITERATE

private static final List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoding> ENCODINGS_TO_ITERATE

numBatchesWritten

private int numBatchesWritten

A zero-based index of the current batch of test data being written

Constructor Detail

TestChangingEncoding

public TestChangingEncoding()

Method Detail

createEncodingsToIterate

private static final List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoding> createEncodingsToIterate()

prepareTest

private void prepareTest(String testId)
                  throws IOException

Throws:

IOException

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

getRowKey

private static byte[] getRowKey(int batchId,
                                int i)

getQualifier

private static byte[] getQualifier(int j)

getValue

private static byte[] getValue(int batchId,
                               int i,
                               int j)

writeTestDataBatch

static void writeTestDataBatch(org.apache.hadoop.hbase.TableName tableName,
                               int batchId)
                        throws Exception

Throws:

Exception

verifyTestDataBatch

static void verifyTestDataBatch(org.apache.hadoop.hbase.TableName tableName,
                                int batchId)
                         throws Exception

Throws:

Exception

writeSomeNewData

private void writeSomeNewData()
                       throws Exception

Throws:

Exception

verifyAllData

private void verifyAllData()
                    throws Exception

Throws:

Exception

setEncodingConf

private void setEncodingConf(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding encoding,
                             boolean onlineChange)
                      throws Exception

Throws:

Exception

testChangingEncoding

public void testChangingEncoding()
                          throws Exception

Throws:

Exception

testChangingEncodingWithCompaction

public void testChangingEncodingWithCompaction()
                                        throws Exception

Throws:

Exception

compactAndWait

private void compactAndWait()
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

testCrazyRandomChanges

public void testCrazyRandomChanges()
                            throws Exception

Throws:

Exception