org.apache.hadoop.hbase.io.hfile

Class TestLruBlockCache

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestLruBlockCache

public class TestLruBlockCache
extends Object

Tests the concurrent LruBlockCache.

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 and Description
private static class	TestLruBlockCache.CachedItem

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
TestLruBlockCache()

Method Summary

Modifier and Type	Method and Description
private long	calculateBlockSize(long maxSize, int numBlocks)
private long	calculateBlockSizeDefault(long maxSize, int numBlocks)
private TestLruBlockCache.CachedItem[]	generateFixedBlocks(int numBlocks, int size, String pfx)
private TestLruBlockCache.CachedItem[]	generateFixedBlocks(int numBlocks, long size, String pfx)
private TestLruBlockCache.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()

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

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

TestLruBlockCache

public TestLruBlockCache()

Method Detail

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 TestLruBlockCache.CachedItem[] generateFixedBlocks(int numBlocks,
                                                           int size,
                                                           String pfx)

generateFixedBlocks

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

generateRandomBlocks

private TestLruBlockCache.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