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

Class TestRecoveryPersistentBucketCache

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.SmallTests") @Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests")
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
(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()
void	testBucketCacheRecoveryWithAllocationInconsistencies()
void	testValidateCacheInitialization()
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

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

@Test
public void testBucketCacheRecovery()
                             throws Exception

Throws:

Exception

testBucketCacheEvictByHFileAfterRecovery

@Test
public void testBucketCacheEvictByHFileAfterRecovery()
                                              throws Exception

Throws:

Exception

testValidateCacheInitialization

@Test
public void testValidateCacheInitialization()
                                     throws Exception

Throws:

Exception

testBucketCacheRecoveryWithAllocationInconsistencies

@Test
public void testBucketCacheRecoveryWithAllocationInconsistencies()
                                                          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