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

Class TestBucketCachePersister

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.IOTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestBucketCachePersister
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final long	capacitySize
int	constructedBlockSize
int[]	constructedBlockSizes
private static final int	DATA_BLOCK_SIZE
private static final org.slf4j.Logger	LOG
private static final int	NUM_KV
private static final int	NUM_VALID_KEY_TYPES
private static final HBaseTestingUtil	TEST_UTIL
(package private) org.apache.hadoop.fs.Path	testDir
(package private) final int	writerQLen
(package private) final int	writeThreads

Constructor Summary

Constructors

Constructor	Description
TestBucketCachePersister()

Method Summary

Modifier and Type	Method	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, String persistentCacheFile)
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 Details

constructedBlockSize

public int constructedBlockSize

LOG

private static final org.slf4j.Logger LOG

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 Details

TestBucketCachePersister

public TestBucketCachePersister()

Method Details

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,
 String persistentCacheFile)
                                                                     throws IOException

Throws:

IOException

cleanupBucketCache

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

Throws:

IOException

testPrefetchPersistenceCrash

@Test
public void testPrefetchPersistenceCrash()
                                  throws Exception

Throws:

Exception

testPrefetchPersistenceCrashNegative

@Test
public void testPrefetchPersistenceCrashNegative()
                                          throws Exception

Throws:

Exception

testPrefetchListUponBlockEviction

@Test
public void testPrefetchListUponBlockEviction()
                                       throws Exception

Throws:

Exception

testPrefetchBlockEvictionWhilePrefetchRunning

@Test
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)