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

Class TestBucketCache.MockedBucketCache

java.lang.Object

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

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

All Implemented Interfaces:

Iterable<org.apache.hadoop.hbase.io.hfile.CachedBlock>, org.apache.hadoop.hbase.io.HeapSize, org.apache.hadoop.hbase.io.hfile.BlockCache

Enclosing class:

TestBucketCache

private static class TestBucketCache.MockedBucketCache
extends org.apache.hadoop.hbase.io.hfile.bucket.BucketCache

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache

org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMCache, org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry, org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread

Field Summary

Fields inherited from class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache

ACCEPT_FACTOR_CONFIG_NAME, backingMap, DEFAULT_ERROR_TOLERATION_DURATION, DEFAULT_MEMORY_FACTOR, DEFAULT_MIN_FACTOR, DEFAULT_MULTI_FACTOR, DEFAULT_SINGLE_FACTOR, DEFAULT_WRITER_QUEUE_ITEMS, DEFAULT_WRITER_THREADS, EXTRA_FREE_FACTOR_CONFIG_NAME, ioEngine, MEMORY_FACTOR_CONFIG_NAME, MIN_FACTOR_CONFIG_NAME, MULTI_FACTOR_CONFIG_NAME, offsetLock, ramCache, SINGLE_FACTOR_CONFIG_NAME, wait_when_cache, writerQueues, writerThreads

Constructor Summary

Constructors

Constructor and Description
MockedBucketCache(String ioEngineName, long capacity, int blockSize, int[] bucketSizes, int writerThreads, int writerQLen, String persistencePath)

Method Summary

Modifier and Type	Method and Description
void	cacheBlock(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey, org.apache.hadoop.hbase.io.hfile.Cacheable buf)
void	cacheBlock(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey, org.apache.hadoop.hbase.io.hfile.Cacheable buf, boolean inMemory)

Methods inherited from class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache

acceptableSize, blockEvicted, cacheBlockWithWait, cacheBlockWithWaitInternal, doDrain, evictBlock, evictBlockIfNoRpcReferenced, evictBlocksByHfileName, evictBucketEntryIfNoRpcReferenced, freeBucketEntry, freeSpace, getAcceptableFactor, getAlgorithm, getAllocator, getBlock, getBlockCaches, getBlockCount, getCurrentDataSize, getCurrentSize, getDataBlockCount, getExtraFreeFactor, getFreeSize, getIoEngine, getMaxSize, getMemoryFactor, getMinFactor, getMultiFactor, getPartitionSize, getRAMQueueEntries, getRealCacheSize, getRpcRefCount, getSingleFactor, getStats, heapSize, isCacheEnabled, iterator, logStats, putIntoBackingMap, removeFromRamCache, shouldReplaceExistingCacheBlock, shutdown, size, startWriterThreads, stopWriterThreads

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.io.hfile.BlockCache

isMetaBlock

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

MockedBucketCache

public MockedBucketCache(String ioEngineName,
                         long capacity,
                         int blockSize,
                         int[] bucketSizes,
                         int writerThreads,
                         int writerQLen,
                         String persistencePath)
                  throws IOException

Throws:

IOException

Method Detail

cacheBlock

public void cacheBlock(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey,
                       org.apache.hadoop.hbase.io.hfile.Cacheable buf,
                       boolean inMemory)

Specified by:

cacheBlock in interface org.apache.hadoop.hbase.io.hfile.BlockCache

Overrides:

cacheBlock in class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache

cacheBlock

public void cacheBlock(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey,
                       org.apache.hadoop.hbase.io.hfile.Cacheable buf)

Specified by:

cacheBlock in interface org.apache.hadoop.hbase.io.hfile.BlockCache

Overrides:

cacheBlock in class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache