org.apache.hadoop.hbase.io.hfile

Class TestPrefetchWithBucketCache

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestPrefetchWithBucketCache

public class TestPrefetchWithBucketCache
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.io.hfile.BlockCache	blockCache
private org.apache.hadoop.hbase.io.hfile.CacheConfig	cacheConf
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static int	DATA_BLOCK_SIZE
private org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static int	NUM_VALID_KEY_TYPES
private static HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestPrefetchWithBucketCache()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.io.hfile.HFile.Reader	createReaderAndWaitForPrefetchInterruption(org.apache.hadoop.fs.Path storeFilePath)
static org.apache.hadoop.hbase.KeyValue.Type	generateKeyType(Random rand)
private void	readStoreFile(org.apache.hadoop.fs.Path storeFilePath)
private void	readStoreFile(org.apache.hadoop.fs.Path storeFilePath, BiFunction<org.apache.hadoop.hbase.io.hfile.HFile.Reader,Long,org.apache.hadoop.hbase.io.hfile.HFileBlock> readFunction, BiConsumer<org.apache.hadoop.hbase.io.hfile.BlockCacheKey,org.apache.hadoop.hbase.io.hfile.HFileBlock> validationFunction)
void	setUp()
void	tearDown()
void	testPrefetchDoesntInterruptInMemoryOnCapacity()
void	testPrefetchDoesntOverwork()
void	testPrefetchInterruptOnCapacity()
private org.apache.hadoop.fs.Path	writeStoreFile(String fname, org.apache.hadoop.hbase.io.hfile.HFileContext context, int numKVs)
private org.apache.hadoop.fs.Path	writeStoreFile(String fname, int numKVs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public org.junit.rules.TestName name

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

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

blockCache

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

Constructor Detail

TestPrefetchWithBucketCache

public TestPrefetchWithBucketCache()

Method Detail

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()

testPrefetchDoesntOverwork

public void testPrefetchDoesntOverwork()
                                throws Exception

Throws:

Exception

testPrefetchInterruptOnCapacity

public void testPrefetchInterruptOnCapacity()
                                     throws Exception

Throws:

Exception

testPrefetchDoesntInterruptInMemoryOnCapacity

public void testPrefetchDoesntInterruptInMemoryOnCapacity()
                                                   throws Exception

Throws:

Exception

readStoreFile

private void readStoreFile(org.apache.hadoop.fs.Path storeFilePath)
                    throws Exception

Throws:

Exception

readStoreFile

private void readStoreFile(org.apache.hadoop.fs.Path storeFilePath,
                           BiFunction<org.apache.hadoop.hbase.io.hfile.HFile.Reader,Long,org.apache.hadoop.hbase.io.hfile.HFileBlock> readFunction,
                           BiConsumer<org.apache.hadoop.hbase.io.hfile.BlockCacheKey,org.apache.hadoop.hbase.io.hfile.HFileBlock> validationFunction)
                    throws Exception

Throws:

Exception

createReaderAndWaitForPrefetchInterruption

private org.apache.hadoop.hbase.io.hfile.HFile.Reader createReaderAndWaitForPrefetchInterruption(org.apache.hadoop.fs.Path storeFilePath)
                                                                                          throws Exception

Throws:

Exception

writeStoreFile

private org.apache.hadoop.fs.Path writeStoreFile(String fname,
                                                 int numKVs)
                                          throws IOException

Throws:

IOException

writeStoreFile

private org.apache.hadoop.fs.Path writeStoreFile(String fname,
                                                 org.apache.hadoop.hbase.io.hfile.HFileContext context,
                                                 int numKVs)
                                          throws IOException

Throws:

IOException

generateKeyType

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