org.apache.hadoop.hbase.master.region

Class TestMasterRegionFlush

java.lang.Object

org.apache.hadoop.hbase.master.region.TestMasterRegionFlush

public class TestMasterRegionFlush
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private AtomicInteger	flushCalled
private org.apache.hadoop.hbase.master.region.MasterRegionFlusherAndCompactor	flusher
private AtomicLong	memstoreHeapSize
private AtomicLong	memstoreOffHeapSize
private org.apache.hadoop.hbase.regionserver.HRegion	region

Constructor Summary

Constructors

Constructor and Description
TestMasterRegionFlush()

Method Summary

Modifier and Type	Method and Description
private void	assertTriggerFlushByChanges(int changes)
private void	initFlusher(long flushSize, long flushPerChanges, long flushIntervalMs)
void	setUp()
void	tearDown()
void	testPeriodicalFlush()
void	testTriggerFlushByChanges()
void	testTriggerFlushBySize()

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

conf

private org.apache.hadoop.conf.Configuration conf

region

private org.apache.hadoop.hbase.regionserver.HRegion region

flusher

private org.apache.hadoop.hbase.master.region.MasterRegionFlusherAndCompactor flusher

flushCalled

private AtomicInteger flushCalled

memstoreHeapSize

private AtomicLong memstoreHeapSize

memstoreOffHeapSize

private AtomicLong memstoreOffHeapSize

Constructor Detail

TestMasterRegionFlush

public TestMasterRegionFlush()

Method Detail

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()

initFlusher

private void initFlusher(long flushSize,
                         long flushPerChanges,
                         long flushIntervalMs)

testTriggerFlushBySize

public void testTriggerFlushBySize()
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

assertTriggerFlushByChanges

private void assertTriggerFlushByChanges(int changes)
                                  throws InterruptedException

Throws:

InterruptedException

testTriggerFlushByChanges

public void testTriggerFlushByChanges()
                               throws InterruptedException

Throws:

InterruptedException

testPeriodicalFlush

public void testPeriodicalFlush()
                         throws InterruptedException

Throws:

InterruptedException