org.apache.hadoop.hbase.regionserver

Class TestHeapMemoryManager

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestHeapMemoryManager

public class TestHeapMemoryManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestHeapMemoryManager.BlockCacheStub
(package private) static class	TestHeapMemoryManager.CustomHeapMemoryTuner
private static class	TestHeapMemoryManager.MemstoreFlusherStub
private static class	TestHeapMemoryManager.RegionServerAccountingStub
private static class	TestHeapMemoryManager.RegionServerStub

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private long	maxHeapSize
private static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestHeapMemoryManager()

Method Summary

Modifier and Type	Method and Description
private void	assertHeapSpace(float expectedHeapPercentage, long currentHeapSpace)
private void	assertHeapSpaceDelta(double expectedDeltaPercent, long oldHeapSpace, long newHeapSpace)
void	testAutoTunerShouldBeOffWhenMaxMinRangesForBlockCacheIsNotGiven()
void	testAutoTunerShouldBeOffWhenMaxMinRangesForMemstoreIsNotGiven()
void	testBlockedFlushesIncreaseMemstoreInSteadyState()
void	testHeapMemoryManagerWhenOffheapFlushesHappenUnderReadHeavyCase()
void	testHeapMemoryManagerWithOffheapMemstoreAndMixedWorkload()
void	testPluggingInHeapMemoryTuner()
void	testWhenClusterIsHavingMoreWritesThanReads()
void	testWhenClusterIsReadHeavy()
void	testWhenClusterIsReadHeavyWithEmptyBlockCache()
void	testWhenClusterIsWriteHeavy()
void	testWhenClusterIsWriteHeavyWithEmptyMemstore()
void	testWhenClusterIsWriteHeavyWithOffheapMemstore()
void	testWhenCombinedHeapSizesFromTunerGoesOutSideMaxLimit()
void	testWhenMemstoreAndBlockCacheMaxMinChecksFails()
void	testWhenSizeGivenByHeapTunerGoesOutsideRange()
private void	waitForTune(TestHeapMemoryManager.MemstoreFlusherStub memStoreFlusher, long oldMemstoreHeapSize)

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

UTIL

private static final HBaseTestingUtility UTIL

maxHeapSize

private long maxHeapSize

Constructor Detail

TestHeapMemoryManager

public TestHeapMemoryManager()

Method Detail

testAutoTunerShouldBeOffWhenMaxMinRangesForMemstoreIsNotGiven

public void testAutoTunerShouldBeOffWhenMaxMinRangesForMemstoreIsNotGiven()
                                                                   throws Exception

Throws:

Exception

testAutoTunerShouldBeOffWhenMaxMinRangesForBlockCacheIsNotGiven

public void testAutoTunerShouldBeOffWhenMaxMinRangesForBlockCacheIsNotGiven()
                                                                     throws Exception

Throws:

Exception

testWhenMemstoreAndBlockCacheMaxMinChecksFails

public void testWhenMemstoreAndBlockCacheMaxMinChecksFails()
                                                    throws Exception

Throws:

Exception

testWhenClusterIsWriteHeavyWithEmptyMemstore

public void testWhenClusterIsWriteHeavyWithEmptyMemstore()
                                                  throws Exception

Throws:

Exception

testHeapMemoryManagerWhenOffheapFlushesHappenUnderReadHeavyCase

public void testHeapMemoryManagerWhenOffheapFlushesHappenUnderReadHeavyCase()
                                                                     throws Exception

Throws:

Exception

testHeapMemoryManagerWithOffheapMemstoreAndMixedWorkload

public void testHeapMemoryManagerWithOffheapMemstoreAndMixedWorkload()
                                                              throws Exception

Throws:

Exception

testWhenClusterIsReadHeavyWithEmptyBlockCache

public void testWhenClusterIsReadHeavyWithEmptyBlockCache()
                                                   throws Exception

Throws:

Exception

testWhenClusterIsWriteHeavy

public void testWhenClusterIsWriteHeavy()
                                 throws Exception

Throws:

Exception

testWhenClusterIsWriteHeavyWithOffheapMemstore

public void testWhenClusterIsWriteHeavyWithOffheapMemstore()
                                                    throws Exception

Throws:

Exception

testWhenClusterIsReadHeavy

public void testWhenClusterIsReadHeavy()
                                throws Exception

Throws:

Exception

testWhenClusterIsHavingMoreWritesThanReads

public void testWhenClusterIsHavingMoreWritesThanReads()
                                                throws Exception

Throws:

Exception

testBlockedFlushesIncreaseMemstoreInSteadyState

public void testBlockedFlushesIncreaseMemstoreInSteadyState()
                                                     throws Exception

Throws:

Exception

testPluggingInHeapMemoryTuner

public void testPluggingInHeapMemoryTuner()
                                   throws Exception

Throws:

Exception

testWhenSizeGivenByHeapTunerGoesOutsideRange

public void testWhenSizeGivenByHeapTunerGoesOutsideRange()
                                                  throws Exception

Throws:

Exception

testWhenCombinedHeapSizesFromTunerGoesOutSideMaxLimit

public void testWhenCombinedHeapSizesFromTunerGoesOutSideMaxLimit()
                                                           throws Exception

Throws:

Exception

assertHeapSpace

private void assertHeapSpace(float expectedHeapPercentage,
                             long currentHeapSpace)

assertHeapSpaceDelta

private void assertHeapSpaceDelta(double expectedDeltaPercent,
                                  long oldHeapSpace,
                                  long newHeapSpace)

waitForTune

private void waitForTune(TestHeapMemoryManager.MemstoreFlusherStub memStoreFlusher,
                         long oldMemstoreHeapSize)
                  throws Exception

Throws:

Exception