Package org.apache.hadoop.hbase

Class TestCacheEviction

java.lang.Object

org.apache.hadoop.hbase.TestCacheEviction

public class TestCacheEviction
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TestCacheEviction()

Method Summary

Modifier and Type	Method	Description
private void	checkCacheForBlocks(org.apache.hadoop.hbase.TableName tableName, Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> files, BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> checker)
private void	checkRegionCached(org.apache.hadoop.hbase.TableName tableName, boolean isCached)
private void	createTable(org.apache.hadoop.hbase.TableName tableName, boolean shouldFlushTable)
private void	doTestEvictOnClose(String table, boolean evictOnClose, BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateBeforeClose, BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateAfterClose)
private void	doTestEvictOnSplit(String table, boolean evictOnSplit, BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateBeforeSplit, BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateAfterSplit)
static void	setUp()
void	testCacheWithFlush()
void	testDoesntEvictOnClose()
void	testDoesntEvictOnSplit()
void	testEvictOnClose()
void	testEvictOnSplit()
void	testNoCacheWithoutFlush()

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

UTIL

private static final HBaseTestingUtil UTIL

Constructor Details

TestCacheEviction

public TestCacheEviction()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

testEvictOnSplit

public void testEvictOnSplit()
                      throws Exception

Throws:

Exception

testDoesntEvictOnSplit

public void testDoesntEvictOnSplit()
                            throws Exception

Throws:

Exception

testEvictOnClose

public void testEvictOnClose()
                      throws Exception

Throws:

Exception

testDoesntEvictOnClose

public void testDoesntEvictOnClose()
                            throws Exception

Throws:

Exception

doTestEvictOnSplit

private void doTestEvictOnSplit(String table,
 boolean evictOnSplit,
 BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateBeforeSplit,
 BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateAfterSplit)
                         throws Exception

Throws:

Exception

doTestEvictOnClose

private void doTestEvictOnClose(String table,
 boolean evictOnClose,
 BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateBeforeClose,
 BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> predicateAfterClose)
                         throws Exception

Throws:

Exception

createTable

private void createTable(org.apache.hadoop.hbase.TableName tableName,
 boolean shouldFlushTable)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

checkCacheForBlocks

private void checkCacheForBlocks(org.apache.hadoop.hbase.TableName tableName,
 Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> files,
 BiConsumer<String,Map<String,org.apache.hadoop.hbase.util.Pair<String,Long>>> checker)

testNoCacheWithoutFlush

public void testNoCacheWithoutFlush()
                             throws Exception

Throws:

Exception

testCacheWithFlush

public void testCacheWithFlush()
                        throws Exception

Throws:

Exception

checkRegionCached

private void checkRegionCached(org.apache.hadoop.hbase.TableName tableName,
 boolean isCached)
                        throws IOException

Throws:

IOException