public class TestVerifyBucketCacheFile extends Object
Modifier and Type | Field and Description |
---|---|
(package private) long |
capacitySize |
static HBaseClassTestRule |
CLASS_RULE |
int |
constructedBlockSize |
int[] |
constructedBlockSizes |
(package private) int |
writerQLen |
(package private) int |
writeThreads |
Constructor and Description |
---|
TestVerifyBucketCacheFile() |
Modifier and Type | Method and Description |
---|---|
private void |
cacheAndWaitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache,
org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey,
org.apache.hadoop.hbase.io.hfile.Cacheable block) |
static Iterable<Object[]> |
data() |
void |
testBucketCacheRecovery()
When using persistent bucket cache, there may be crashes between persisting the backing map and
syncing new blocks to the cache file itself, leading to an inconsistent state between the cache
keys and the cached data.
|
void |
testModifiedBucketCacheFileData()
Test whether BucketCache is started normally after modifying the cache file.
|
void |
testModifiedBucketCacheFileTime()
Test whether BucketCache is started normally after modifying the cache file's last modified
time.
|
void |
testRetrieveFromFile()
Test cache file or persistence file does not exist whether BucketCache starts normally (1)
Start BucketCache and add some blocks, then shutdown BucketCache and persist cache to file.
|
void |
testRetrieveFromFileAfterDelete() |
private void |
waitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache,
org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey) |
public static final HBaseClassTestRule CLASS_RULE
public int constructedBlockSize
public int[] constructedBlockSizes
final long capacitySize
final int writeThreads
final int writerQLen
public TestVerifyBucketCacheFile()
public void testRetrieveFromFile() throws Exception
Exception
- the exceptionpublic void testRetrieveFromFileAfterDelete() throws Exception
Exception
public void testModifiedBucketCacheFileData() throws Exception
Exception
- the exceptionpublic void testModifiedBucketCacheFileTime() throws Exception
Exception
- the exceptionpublic void testBucketCacheRecovery() throws Exception
Exception
- the exceptionprivate void waitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache, org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey) throws InterruptedException
InterruptedException
private void cacheAndWaitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache, org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey, org.apache.hadoop.hbase.io.hfile.Cacheable block) throws InterruptedException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.