Package org.apache.hadoop.hbase.io.encoding

Class TestChangingEncoding

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.IOTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestChangingEncoding
extends Object

Tests changing data block encoding settings of a column family.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	CF
(package private) static final byte[]	CF_BYTES
private org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder	columnFamilyDescriptorBuilder
private static final org.apache.hadoop.conf.Configuration	conf
private static final List<org.apache.hadoop.hbase.io.encoding.DataBlockEncoding>	ENCODINGS_TO_ITERATE
private static final org.slf4j.Logger	LOG
private static final int	NUM_COLS_PER_ROW
private static final 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 final HBaseTestingUtil	TEST_UTIL
private static final int	TIMEOUT_MS

Constructor Summary

Constructors

Constructor	Description
TestChangingEncoding()

Method Summary

Modifier and Type	Method	Description
private void	compactAndWait()
private static final 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 Details

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 HBaseTestingUtil 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

columnFamilyDescriptorBuilder

private org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder columnFamilyDescriptorBuilder

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 Details

TestChangingEncoding

public TestChangingEncoding()

Method Details

createEncodingsToIterate

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

prepareTest

private void prepareTest(String testId)
                  throws IOException

Throws:

IOException

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
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

@Test
public void testChangingEncoding()
                          throws Exception

Throws:

Exception

testChangingEncodingWithCompaction

@Test
public void testChangingEncodingWithCompaction()
                                        throws Exception

Throws:

Exception

compactAndWait

private void compactAndWait()
                     throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testCrazyRandomChanges

@Test
public void testCrazyRandomChanges()
                            throws Exception

Throws:

Exception