org.apache.hadoop.hbase.io.hfile.bucket

Class TestBucketCachePersister

java.lang.Object

org.apache.hadoop.hbase.io.hfile.bucket.TestBucketCachePersister

public class TestBucketCachePersister
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	capacitySize
static HBaseClassTestRule	CLASS_RULE
int	constructedBlockSize
int[]	constructedBlockSizes
private static int	DATA_BLOCK_SIZE
org.junit.rules.TestName	name
private static int	NUM_KV
private static int	NUM_VALID_KEY_TYPES
private static HBaseTestingUtil	TEST_UTIL
(package private) org.apache.hadoop.fs.Path	testDir
(package private) int	writerQLen
(package private) int	writeThreads

Constructor Summary

Constructors

Constructor and Description
TestBucketCachePersister()

Method Summary

Modifier and Type	Method and Description
void	cleanupBucketCache(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bucketCache)
static org.apache.hadoop.hbase.KeyValue.Type	generateKeyType(Random rand)
void	readStoreFile(org.apache.hadoop.fs.Path storeFilePath, long offset, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bucketCache)
org.apache.hadoop.hbase.io.hfile.bucket.BucketCache	setupBucketCache(org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.conf.Configuration	setupBucketCacheConfig(long bucketCachePersistInterval)
void	testPrefetchBlockEvictionWhilePrefetchRunning()
void	testPrefetchListUponBlockEviction()
void	testPrefetchPersistenceCrash()
void	testPrefetchPersistenceCrashNegative()
org.apache.hadoop.fs.Path	writeStoreFile(String fname, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf, org.apache.hadoop.fs.FileSystem fs)

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

name

public org.junit.rules.TestName name

constructedBlockSize

public int constructedBlockSize

constructedBlockSizes

public int[] constructedBlockSizes

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

NUM_VALID_KEY_TYPES

private static final int NUM_VALID_KEY_TYPES

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

capacitySize

final long capacitySize

See Also:

Constant Field Values

writeThreads

final int writeThreads

See Also:

Constant Field Values

writerQLen

final int writerQLen

See Also:

Constant Field Values

testDir

org.apache.hadoop.fs.Path testDir

Constructor Detail

TestBucketCachePersister

public TestBucketCachePersister()

Method Detail

setupBucketCacheConfig

public org.apache.hadoop.conf.Configuration setupBucketCacheConfig(long bucketCachePersistInterval)
                                                            throws IOException

Throws:

IOException

setupBucketCache

public org.apache.hadoop.hbase.io.hfile.bucket.BucketCache setupBucketCache(org.apache.hadoop.conf.Configuration conf)
                                                                     throws IOException

Throws:

IOException

cleanupBucketCache

public void cleanupBucketCache(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bucketCache)
                        throws IOException

Throws:

IOException

testPrefetchPersistenceCrash

public void testPrefetchPersistenceCrash()
                                  throws Exception

Throws:

Exception

testPrefetchPersistenceCrashNegative

public void testPrefetchPersistenceCrashNegative()
                                          throws Exception

Throws:

Exception

testPrefetchListUponBlockEviction

public void testPrefetchListUponBlockEviction()
                                       throws Exception

Throws:

Exception

testPrefetchBlockEvictionWhilePrefetchRunning

public void testPrefetchBlockEvictionWhilePrefetchRunning()
                                                   throws Exception

Throws:

Exception

readStoreFile

public void readStoreFile(org.apache.hadoop.fs.Path storeFilePath,
                          long offset,
                          org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf,
                          org.apache.hadoop.conf.Configuration conf,
                          org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bucketCache)
                   throws Exception

Throws:

Exception

writeStoreFile

public org.apache.hadoop.fs.Path writeStoreFile(String fname,
                                                org.apache.hadoop.conf.Configuration conf,
                                                org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf,
                                                org.apache.hadoop.fs.FileSystem fs)
                                         throws IOException

Throws:

IOException

generateKeyType

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