org.apache.hadoop.hbase.regionserver

Class TestCompaction

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompaction

Direct Known Subclasses:

TestCompactionWithCoprocessor

public class TestCompaction
extends Object

Test compaction framework and common functions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TestCompaction.BlockingStoreMockMaker
static class	TestCompaction.DummyCompactor
static class	TestCompaction.TrackableCompactionRequest Simple CompactionRequest on which you can wait until the requested compaction finishes.

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	conf
TestName	name

Constructor Summary

Constructors

Constructor and Description
TestCompaction() constructor

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	tearDown()
void	testCompactionQueuePriorities() Test compaction priority management and multiple compactions per store (HBASE-8665).
void	testCompactionSeqId() Firstly write 10 cells (with different time stamp) to a qualifier and flush to hfile1, then write 10 cells (with different time stamp) to the same qualifier and flush to hfile2.
void	testCompactionWithCorruptResult()
void	testInterruptCompaction() Verify that you can stop a long-running compaction (used during RS shutdown)
void	testMultipleCustomCompactionRequests() HBASE-7947: Regression test to ensure adding to the correct list in the CompactSplitThread
void	testTrackingCompactionRequest() Create a custom compaction request and be sure that we can track it through the queue, knowing when the compaction is completed.

Methods inherited from class java.lang.Object

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

Field Detail

name

public TestName name

conf

protected Configuration conf

Constructor Detail

TestCompaction

public TestCompaction()

constructor

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testInterruptCompaction

public void testInterruptCompaction()
                             throws Exception

Verify that you can stop a long-running compaction (used during RS shutdown)

Throws:

Exception

testCompactionWithCorruptResult

public void testCompactionWithCorruptResult()
                                     throws Exception

Throws:

Exception

testTrackingCompactionRequest

public void testTrackingCompactionRequest()
                                   throws Exception

Create a custom compaction request and be sure that we can track it through the queue, knowing when the compaction is completed.

Throws:

Exception

testMultipleCustomCompactionRequests

public void testMultipleCustomCompactionRequests()
                                          throws Exception

HBASE-7947: Regression test to ensure adding to the correct list in the CompactSplitThread

Throws:

Exception - on failure

testCompactionQueuePriorities

public void testCompactionQueuePriorities()
                                   throws Exception

Test compaction priority management and multiple compactions per store (HBASE-8665).

Throws:

Exception

testCompactionSeqId

public void testCompactionSeqId()
                         throws Exception

Firstly write 10 cells (with different time stamp) to a qualifier and flush to hfile1, then write 10 cells (with different time stamp) to the same qualifier and flush to hfile2. The latest cell (cell-A) in hfile1 and the oldest cell (cell-B) in hfile2 are with the same time stamp but different sequence id, and will get scanned successively during compaction.

We set compaction.kv.max to 10 so compaction will scan 10 versions each round, meanwhile we set keepSeqIdPeriod=0 in TestCompaction.DummyCompactor so all 10 versions of hfile2 will be written out with seqId cleaned (set to 0) including cell-B, then when scanner goes to cell-A it will cause a scan out-of-order assertion error before HBASE-16931

Throws:

Exception - if error occurs during the test