Package org.apache.hadoop.hbase.io.hfile

Class TestLruAdaptiveBlockCache

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestLruAdaptiveBlockCache

public class TestLruAdaptiveBlockCache
extends Object

Tests the concurrent LruAdaptiveBlockCache.

Tests will ensure it grows and shrinks in size properly, evictions run when they're supposed to and do what they should, and that cached blocks are accessible when expected to be.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestLruAdaptiveBlockCache.CachedItem

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.apache.hadoop.conf.Configuration	CONF
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
TestLruAdaptiveBlockCache()

Method Summary

Modifier and Type	Method	Description
private long	calculateBlockSize(long maxSize, int numBlocks)
private long	calculateBlockSizeDefault(long maxSize, int numBlocks)
private TestLruAdaptiveBlockCache.CachedItem[]	generateFixedBlocks(int numBlocks, int size, String pfx)
private TestLruAdaptiveBlockCache.CachedItem[]	generateFixedBlocks(int numBlocks, long size, String pfx)
private TestLruAdaptiveBlockCache.CachedItem[]	generateRandomBlocks(int numBlocks, long maxSize)
void	testBackgroundEvictionThread()
void	testCacheBlockNextBlockMetadataMissing()
void	testCacheEvictionInMemoryForceMode()
void	testCacheEvictionSimple()
void	testCacheEvictionThreadSafe()
void	testCacheEvictionThreePriorities()
void	testCacheEvictionTwoPriorities()
void	testCacheSimple()
void	testMaxBlockSize()
void	testMultiThreadGetAndEvictBlock()
(package private) static void	testMultiThreadGetAndEvictBlockInternal(org.apache.hadoop.hbase.io.hfile.BlockCache cache)
void	testPastNPeriodsMetrics()
void	testResizeBlockCache()
void	testScanResistance()
void	testSkipCacheDataBlocks()
void	testSkipCacheDataBlocksInteral(int heavyEvictionCountLimit)

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

LOG

private static final org.slf4j.Logger LOG

CONF

private static final org.apache.hadoop.conf.Configuration CONF

Constructor Details

TestLruAdaptiveBlockCache

public TestLruAdaptiveBlockCache()

Method Details

testCacheEvictionThreadSafe

public void testCacheEvictionThreadSafe()
                                 throws Exception

Throws:

Exception

testBackgroundEvictionThread

public void testBackgroundEvictionThread()
                                  throws Exception

Throws:

Exception

testCacheSimple

public void testCacheSimple()
                     throws Exception

Throws:

Exception

testCacheEvictionSimple

public void testCacheEvictionSimple()
                             throws Exception

Throws:

Exception

testCacheEvictionTwoPriorities

public void testCacheEvictionTwoPriorities()
                                    throws Exception

Throws:

Exception

testCacheEvictionThreePriorities

public void testCacheEvictionThreePriorities()
                                      throws Exception

Throws:

Exception

testCacheEvictionInMemoryForceMode

public void testCacheEvictionInMemoryForceMode()
                                        throws Exception

Throws:

Exception

testScanResistance

public void testScanResistance()
                        throws Exception

Throws:

Exception

testMaxBlockSize

public void testMaxBlockSize()
                      throws Exception

Throws:

Exception

testResizeBlockCache

public void testResizeBlockCache()
                          throws Exception

Throws:

Exception

testPastNPeriodsMetrics

public void testPastNPeriodsMetrics()
                             throws Exception

Throws:

Exception

testCacheBlockNextBlockMetadataMissing

public void testCacheBlockNextBlockMetadataMissing()

generateFixedBlocks

private TestLruAdaptiveBlockCache.CachedItem[] generateFixedBlocks(int numBlocks,
 int size,
 String pfx)

generateFixedBlocks

private TestLruAdaptiveBlockCache.CachedItem[] generateFixedBlocks(int numBlocks,
 long size,
 String pfx)

generateRandomBlocks

private TestLruAdaptiveBlockCache.CachedItem[] generateRandomBlocks(int numBlocks,
 long maxSize)

calculateBlockSize

private long calculateBlockSize(long maxSize,
 int numBlocks)

calculateBlockSizeDefault

private long calculateBlockSizeDefault(long maxSize,
 int numBlocks)

testMultiThreadGetAndEvictBlockInternal

static void testMultiThreadGetAndEvictBlockInternal(org.apache.hadoop.hbase.io.hfile.BlockCache cache)
                                             throws Exception

Throws:

Exception

testMultiThreadGetAndEvictBlock

public void testMultiThreadGetAndEvictBlock()
                                     throws Exception

Throws:

Exception

testSkipCacheDataBlocksInteral

public void testSkipCacheDataBlocksInteral(int heavyEvictionCountLimit)
                                    throws Exception

Throws:

Exception

testSkipCacheDataBlocks

public void testSkipCacheDataBlocks()
                             throws Exception

Throws:

Exception