public class TestBucketCachePersister extends Object
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 and Description |
---|
TestBucketCachePersister() |
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 |
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) |
public static final HBaseClassTestRule CLASS_RULE
public org.junit.rules.TestName name
public int constructedBlockSize
public int[] constructedBlockSizes
private static final HBaseTestingUtil TEST_UTIL
private static final int NUM_VALID_KEY_TYPES
private static final int DATA_BLOCK_SIZE
private static final int NUM_KV
final long capacitySize
final int writeThreads
final int writerQLen
org.apache.hadoop.fs.Path testDir
public TestBucketCachePersister()
public org.apache.hadoop.conf.Configuration setupBucketCacheConfig(long bucketCachePersistInterval) throws IOException
IOException
public org.apache.hadoop.hbase.io.hfile.bucket.BucketCache setupBucketCache(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public void cleanupBucketCache(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bucketCache) throws IOException
IOException
public void testPrefetchPersistenceCrash() throws Exception
Exception
public void testPrefetchPersistenceCrashNegative() throws Exception
Exception
public void testPrefetchListUponBlockEviction() throws Exception
Exception
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
Exception
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
IOException
public static org.apache.hadoop.hbase.KeyValue.Type generateKeyType(Random rand)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.