Package org.apache.hadoop.hbase.master.normalizer

Class TestRegionNormalizerWorker

java.lang.Object

org.apache.hadoop.hbase.master.normalizer.TestRegionNormalizerWorker

public class TestRegionNormalizerWorker
extends Object

A test over RegionNormalizerWorker. Being a background thread, the only points of interaction we have to this class are its input source (RegionNormalizerWorkQueue and its callbacks invoked against RegionNormalizer and MasterServices. The work queue is simple enough to use directly; for MasterServices, use a mock because, as of now, the worker only invokes 4 methods.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.master.MasterServices	masterServices
org.mockito.junit.MockitoRule	mockitoRule
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<org.apache.hadoop.hbase.TableName>	queue
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizer	regionNormalizer
TableNameTestRule	tableName
private HBaseCommonTestingUtil	testingUtility
org.junit.rules.TestName	testName
private ExecutorService	workerPool
private final AtomicReference<Throwable>	workerThreadThrowable

Constructor Summary

Constructors

Constructor	Description
TestRegionNormalizerWorker()

Method Summary

Modifier and Type	Method	Description
void	after()
private <T> void	assertThatEventually(String reason, Supplier<? extends T> actualSupplier, org.hamcrest.Matcher<? super T> matcher)	Repeatedly evaluates matcher against the result of calling actualSupplier until the matcher succeeds or the timeout period of 30 seconds is exhausted.
void	before()
void	testMergeCounter()
void	testPlansSizeLimit()
void	testRateLimit()	Assert that a rate limit is honored, at least in a rough way.
void	testSplitCounter()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testName

public org.junit.rules.TestName testName

tableName

public TableNameTestRule tableName

mockitoRule

public org.mockito.junit.MockitoRule mockitoRule

masterServices

@Mock(answer=RETURNS_DEEP_STUBS)
private org.apache.hadoop.hbase.master.MasterServices masterServices

regionNormalizer

@Mock
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizer regionNormalizer

testingUtility

private HBaseCommonTestingUtil testingUtility

queue

private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<org.apache.hadoop.hbase.TableName> queue

workerPool

private ExecutorService workerPool

workerThreadThrowable

private final AtomicReference<Throwable> workerThreadThrowable

Constructor Details

TestRegionNormalizerWorker

public TestRegionNormalizerWorker()

Method Details

before

public void before()
            throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

testMergeCounter

public void testMergeCounter()
                      throws Exception

Throws:

Exception

testSplitCounter

public void testSplitCounter()
                      throws Exception

Throws:

Exception

testRateLimit

public void testRateLimit()
                   throws Exception

Assert that a rate limit is honored, at least in a rough way. Maintainers should manually inspect the log messages emitted by the worker thread to confirm that expected behavior.

Throws:

Exception

testPlansSizeLimit

public void testPlansSizeLimit()
                        throws Exception

Throws:

Exception

assertThatEventually

private <T> void assertThatEventually(String reason,
 Supplier<? extends T> actualSupplier,
 org.hamcrest.Matcher<? super T> matcher)
                               throws Exception

Repeatedly evaluates matcher against the result of calling actualSupplier until the matcher succeeds or the timeout period of 30 seconds is exhausted.

Throws:

Exception