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

Class TestBucketCacheRefCnt.MyBucketCache2

java.lang.Object
org.apache.hadoop.hbase.io.hfile.bucket.BucketCache
org.apache.hadoop.hbase.io.hfile.bucket.TestBucketCacheRefCnt.MyBucketCache2
All Implemented Interfaces:
Iterable<org.apache.hadoop.hbase.io.hfile.CachedBlock>, org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.io.HeapSize, org.apache.hadoop.hbase.io.hfile.BlockCache
Enclosing class:
TestBucketCacheRefCnt
static class TestBucketCacheRefCnt.MyBucketCache2 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.CacheState, 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
    Modifier and Type
    Field
    Description
    private final AtomicInteger
    blockEvictCounter
     
    private static final String
    CACHE_BLOCK_THREAD_NAME
     
    private static final String
    EVICT_BLOCK_THREAD_NAME
     
    private final CyclicBarrier
    evictCyclicBarrier
     
    private final AtomicInteger
    freeBucketEntryCounter
     
    private static final String
    GET_BLOCK_THREAD_NAME
     
    private final CyclicBarrier
    getCyclicBarrier
     
    private org.apache.hadoop.hbase.nio.ByteBuff
    overwiteByteBuff
     
    private final CyclicBarrier
    putCyclicBarrier
     
    private final AtomicInteger
    removeRamCounter
     
    private final CyclicBarrier
    writeThreadDoneCyclicBarrier
    This is used for BucketCache.WriterThread,CACHE_BLOCK_THREAD_NAME and EVICT_BLOCK_THREAD_NAME,waiting for caching block completed.

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

    ACCEPT_FACTOR_CONFIG_NAME, BACKING_MAP_PERSISTENCE_CHUNK_SIZE, backingMap, BLOCK_ORPHAN_GRACE_PERIOD, BLOCK_ORPHAN_GRACE_PERIOD_DEFAULT, blocksByHFile, DEFAULT_ACCEPT_FACTOR, DEFAULT_BACKING_MAP_PERSISTENCE_CHUNK_SIZE, DEFAULT_ERROR_TOLERATION_DURATION, DEFAULT_EXTRA_FREE_FACTOR, DEFAULT_FREE_ENTIRE_BLOCK_FACTOR, DEFAULT_MEMORY_FACTOR, DEFAULT_MIN_FACTOR, DEFAULT_MULTI_FACTOR, DEFAULT_SINGLE_FACTOR, DEFAULT_WRITER_QUEUE_ITEMS, DEFAULT_WRITER_THREADS, EXTRA_FREE_FACTOR_CONFIG_NAME, fullyCachedFiles, ioEngine, isCacheInconsistent, MEMORY_FACTOR_CONFIG_NAME, MIN_FACTOR_CONFIG_NAME, MULTI_FACTOR_CONFIG_NAME, offsetLock, QUEUE_ADDITION_WAIT_TIME, ramCache, regionCachedSize, SINGLE_FACTOR_CONFIG_NAME, writerQueues, writerThreads

  • Constructor Summary

    Constructors
    Constructor
    Description
    MyBucketCache2(String ioEngineName, long capacity, int blockSize, int[] bucketSizes, int writerThreadNum, int writerQLen, String persistencePath)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) void
    blockEvicted(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey, org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry bucketEntry, boolean decrementBlockNumber, boolean evictedByEvictionProcess)
     
    (package private) void
    doDrain(List<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry> entries, ByteBuffer metaBuff)
     
    (package private) void
    freeBucketEntry(org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry bucketEntry)
    Overwrite 0xff to the BucketEntry content to simulate it would be overwrite after the BucketEntry is freed.
    org.apache.hadoop.hbase.io.hfile.Cacheable
    getBlock(org.apache.hadoop.hbase.io.hfile.BlockCacheKey key, boolean caching, boolean repeat, boolean updateCacheMetrics)
     
    protected void
    putIntoBackingMap(org.apache.hadoop.hbase.io.hfile.BlockCacheKey key, org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry bucketEntry)
     
    protected boolean
    removeFromRamCache(org.apache.hadoop.hbase.io.hfile.BlockCacheKey cacheKey)
     

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

    acceptableSize, blockFitsIntoTheCache, cacheBlock, cacheBlock, cacheBlock, cacheBlockWithWait, cacheBlockWithWaitInternal, createRecycler, evictBlock, evictBlockIfNoRpcReferenced, evictBlocksByHfileName, evictBlocksRangeByHfileName, evictBucketEntryIfNoRpcReferenced, fileCacheCompleted, finalize, freeSpace, getAcceptableFactor, getAlgorithm, getAllocator, getBackingMap, getBackingMapValidated, getBlockCaches, getBlockCount, getBlockForReference, getBlockSize, getBucketCacheFromCacheConfig, getBucketcachePersistInterval, getCurrentDataSize, getCurrentSize, getDataBlockCount, getExtraFreeFactor, getFreeSize, getFullyCachedFiles, getIoEngine, getMaxSize, getMemoryFactor, getMinFactor, getMultiFactor, getPartitionSize, getPersistenceChunkSize, getPersistencePath, getQueueAdditionWaitTime, getRAMQueueEntries, getRealCacheSize, getRegionCachedInfo, getRpcRefCount, getSingleFactor, getStats, heapSize, isAlreadyCached, isCacheEnabled, isCacheInconsistent, isCacheInitialized, isCachePersistenceEnabled, isCachePersistent, iterator, logStats, notifyFileCachingCompleted, onConfigurationChange, persistToFile, setCacheInconsistent, setCacheState, shouldCacheBlock, shouldCacheFile, shouldReplaceExistingCacheBlock, shutdown, size, startBucketCachePersisterThread, startWriterThreads, stopWriterThreads, waitForCacheInitialization

    Methods inherited from class java.lang.Object

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

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

    getBlock, isMetaBlock

    Methods inherited from interface java.lang.Iterable

    forEach, spliterator