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

Class TestRecoveryPersistentBucketCache

java.lang.Object

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

public class TestRecoveryPersistentBucketCache
extends Object

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final long	capacitySize
static final HBaseClassTestRule	CLASS_RULE
(package private) final int	writerQLen
(package private) final int	writeThreads

Constructor Summary

Constructors

Constructor	Description
TestRecoveryPersistentBucketCache()

Method Summary

Modifier and Type	Method	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)
void	testBucketCacheEvictByHFileAfterRecovery()
void	testBucketCacheRecovery()
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 Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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 Details

TestRecoveryPersistentBucketCache

public TestRecoveryPersistentBucketCache()

Method Details

testBucketCacheRecovery

public void testBucketCacheRecovery()
                             throws Exception

Throws:

Exception

testBucketCacheEvictByHFileAfterRecovery

public void testBucketCacheEvictByHFileAfterRecovery()
                                              throws Exception

Throws:

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