org.apache.hadoop.hbase.io.hfile

Class TestCacheOnWrite

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestCacheOnWrite

public class TestCacheOnWrite
extends Object

Tests HFile cache-on-write functionality for the following block types: data blocks, non-root index blocks, and Bloom filter blocks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestCacheOnWrite.CacheOnWriteType

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.io.hfile.BlockCache	blockCache
private static int	BLOOM_BLOCK_SIZE
private static org.apache.hadoop.hbase.regionserver.BloomType	BLOOM_TYPE
private boolean	cacheCompressedData
private org.apache.hadoop.hbase.io.hfile.CacheConfig	cacheConf
private static int	CKBYTES
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.io.compress.Compression.Algorithm	compress
private org.apache.hadoop.conf.Configuration	conf
private TestCacheOnWrite.CacheOnWriteType	cowType
private static int	DATA_BLOCK_SIZE
private org.apache.hadoop.fs.FileSystem	fs
private static int	INDEX_BLOCK_SIZE
private static org.slf4j.Logger	LOG
private static int	NUM_KV
private static int	NUM_VALID_KEY_TYPES The number of valid key types possible in a store file
private Random	rand
private org.apache.hadoop.fs.Path	storeFilePath
private static HBaseTestingUtility	TEST_UTIL
private String	testDescription

Constructor Summary

Constructors

Constructor and Description
TestCacheOnWrite(TestCacheOnWrite.CacheOnWriteType cowType, org.apache.hadoop.hbase.io.compress.Compression.Algorithm compress, boolean cacheCompressedData, org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
private void	clearBlockCache(org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)
static org.apache.hadoop.hbase.KeyValue.Type	generateKeyType(Random rand)
private static List<org.apache.hadoop.hbase.io.hfile.BlockCache>	getBlockCaches()
static Collection<Object[]>	getParameters()
private void	readStoreFile(boolean useTags)
void	setUp()
void	tearDown()
void	testNotCachingDataBlocksDuringCompaction()
private void	testNotCachingDataBlocksDuringCompactionInternals(boolean useTags)
void	testStoreFileCacheOnWrite()
private void	testStoreFileCacheOnWriteInternals(boolean useTags)
private void	writeStoreFile(boolean useTags)

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

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

conf

private org.apache.hadoop.conf.Configuration conf

cacheConf

private org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf

fs

private org.apache.hadoop.fs.FileSystem fs

rand

private Random rand

storeFilePath

private org.apache.hadoop.fs.Path storeFilePath

blockCache

private org.apache.hadoop.hbase.io.hfile.BlockCache blockCache

testDescription

private String testDescription

cowType

private final TestCacheOnWrite.CacheOnWriteType cowType

compress

private final org.apache.hadoop.hbase.io.compress.Compression.Algorithm compress

cacheCompressedData

private final boolean cacheCompressedData

DATA_BLOCK_SIZE

private static final int DATA_BLOCK_SIZE

See Also:

Constant Field Values

NUM_KV

private static final int NUM_KV

See Also:

Constant Field Values

INDEX_BLOCK_SIZE

private static final int INDEX_BLOCK_SIZE

See Also:

Constant Field Values

BLOOM_BLOCK_SIZE

private static final int BLOOM_BLOCK_SIZE

See Also:

Constant Field Values

BLOOM_TYPE

private static final org.apache.hadoop.hbase.regionserver.BloomType BLOOM_TYPE

CKBYTES

private static final int CKBYTES

See Also:

Constant Field Values

NUM_VALID_KEY_TYPES

private static final int NUM_VALID_KEY_TYPES

The number of valid key types possible in a store file

Constructor Detail

TestCacheOnWrite

public TestCacheOnWrite(TestCacheOnWrite.CacheOnWriteType cowType,
                        org.apache.hadoop.hbase.io.compress.Compression.Algorithm compress,
                        boolean cacheCompressedData,
                        org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)

Method Detail

getBlockCaches

private static List<org.apache.hadoop.hbase.io.hfile.BlockCache> getBlockCaches()
                                                                         throws IOException

Throws:

IOException

getParameters

public static Collection<Object[]> getParameters()
                                          throws IOException

Throws:

IOException

clearBlockCache

private void clearBlockCache(org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)
                      throws InterruptedException

Throws:

InterruptedException

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws IOException,
                     InterruptedException

Throws:

IOException

InterruptedException

afterClass

public static void afterClass()
                       throws IOException

Throws:

IOException

testStoreFileCacheOnWriteInternals

private void testStoreFileCacheOnWriteInternals(boolean useTags)
                                         throws IOException

Throws:

IOException

readStoreFile

private void readStoreFile(boolean useTags)
                    throws IOException

Throws:

IOException

generateKeyType

public static org.apache.hadoop.hbase.KeyValue.Type generateKeyType(Random rand)

writeStoreFile

private void writeStoreFile(boolean useTags)
                     throws IOException

Throws:

IOException

testNotCachingDataBlocksDuringCompactionInternals

private void testNotCachingDataBlocksDuringCompactionInternals(boolean useTags)
                                                        throws IOException,
                                                               InterruptedException

Throws:

IOException

InterruptedException

testStoreFileCacheOnWrite

public void testStoreFileCacheOnWrite()
                               throws IOException

Throws:

IOException

testNotCachingDataBlocksDuringCompaction

public void testNotCachingDataBlocksDuringCompaction()
                                              throws IOException,
                                                     InterruptedException

Throws:

IOException

InterruptedException