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

Class TestVerifyBucketCacheFile

java.lang.Object

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

public class TestVerifyBucketCacheFile
extends Object

Basic test for check file's integrity before start BucketCache in fileIOEngine

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
TestVerifyBucketCacheFile()

Method Summary

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	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.
private void	waitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache, org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey)

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

constructedBlockSize

public int constructedBlockSize

constructedBlockSizes

public int[] constructedBlockSizes

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

Constructor Detail

TestVerifyBucketCacheFile

public TestVerifyBucketCacheFile()

Method Detail

data

public static Iterable<Object[]> data()

testRetrieveFromFile

public void testRetrieveFromFile()
                          throws Exception

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. Restart BucketCache and it can restore cache from file. (2) Delete bucket cache file after shutdown BucketCache. Restart BucketCache and it can't restore cache from file, the cache file and persistence file would be deleted before BucketCache start normally. (3) Delete persistence file after shutdown BucketCache. Restart BucketCache and it can't restore cache from file, the cache file and persistence file would be deleted before BucketCache start normally.

Throws:

Exception - the exception

testModifiedBucketCacheFileData

public void testModifiedBucketCacheFileData()
                                     throws Exception

Test whether BucketCache is started normally after modifying the cache file. Start BucketCache and add some blocks, then shutdown BucketCache and persist cache to file. Restart BucketCache after modify cache file's data, and it can't restore cache from file, the cache file and persistence file would be deleted before BucketCache start normally.

Throws:

Exception - the exception

testModifiedBucketCacheFileTime

public void testModifiedBucketCacheFileTime()
                                     throws Exception

Test whether BucketCache is started normally after modifying the cache file's last modified time. First Start BucketCache and add some blocks, then shutdown BucketCache and persist cache to file. Then Restart BucketCache after modify cache file's last modified time, and it can't restore cache from file, the cache file and persistence file would be deleted before BucketCache start normally.

Throws:

Exception - the exception

waitUntilFlushedToBucket

private void waitUntilFlushedToBucket(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache cache,
                                      org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey)
                               throws InterruptedException

Throws:

InterruptedException

cacheAndWaitUntilFlushedToBucket

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

Throws:

InterruptedException