@InterfaceAudience.Private public class CombinedBlockCache extends Object implements ResizableBlockCache, HeapSize
LruBlockCache and BucketCache. The smaller lruCache is used
to cache bloom blocks and index blocks. The larger l2Cache is used to
cache data blocks. getBlock(BlockCacheKey, boolean, boolean, boolean) reads
first from the smaller lruCache before looking for the block in the l2Cache. Blocks evicted
from lruCache are put into the bucket cache.
Metrics are the combined size and hits and misses of both caches.| Modifier and Type | Class and Description |
|---|---|
static class |
CombinedBlockCache.CombinedCacheStats |
| Modifier and Type | Field and Description |
|---|---|
protected CombinedBlockCache.CombinedCacheStats |
combinedCacheStats |
protected BlockCache |
l2Cache |
protected LruBlockCache |
lruCache |
| Constructor and Description |
|---|
CombinedBlockCache(LruBlockCache lruCache,
BlockCache l2Cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
cacheBlock(BlockCacheKey cacheKey,
Cacheable buf)
Add block to cache (defaults to not in-memory).
|
void |
cacheBlock(BlockCacheKey cacheKey,
Cacheable buf,
boolean inMemory,
boolean cacheDataInL1)
Add block to cache.
|
boolean |
evictBlock(BlockCacheKey cacheKey)
Evict block from cache.
|
int |
evictBlocksByHfileName(String hfileName)
Evicts all blocks for the given HFile.
|
Cacheable |
getBlock(BlockCacheKey cacheKey,
boolean caching,
boolean repeat,
boolean updateCacheMetrics)
Fetch block from cache.
|
BlockCache[] |
getBlockCaches() |
long |
getBlockCount()
Returns the number of blocks currently cached in the block cache.
|
long |
getCurrentSize()
Returns the occupied size of the block cache, in bytes.
|
long |
getFreeSize()
Returns the free size of the block cache, in bytes.
|
CacheStats |
getStats()
Get the statistics for this block cache.
|
long |
heapSize() |
Iterator<CachedBlock> |
iterator() |
void |
setMaxSize(long size)
Sets the max heap size that can be used by the BlockCache.
|
void |
shutdown()
Shutdown the cache.
|
long |
size()
Returns the total size of the block cache, in bytes.
|
protected final LruBlockCache lruCache
protected final BlockCache l2Cache
protected final CombinedBlockCache.CombinedCacheStats combinedCacheStats
public CombinedBlockCache(LruBlockCache lruCache, BlockCache l2Cache)
public long heapSize()
public void cacheBlock(BlockCacheKey cacheKey, Cacheable buf, boolean inMemory, boolean cacheDataInL1)
BlockCachecacheBlock in interface BlockCachecacheKey - The block's cache key.buf - The block contents wrapped in a ByteBuffer.inMemory - Whether block should be treated as in-memorycacheDataInL1 - If multi-tier block cache deploy -- i.e. has an L1 and L2 tier -- then
if this flag is true, cache data blocks up in the L1 tier (meta blocks are probably being
cached in L1 already).public void cacheBlock(BlockCacheKey cacheKey, Cacheable buf)
BlockCachecacheBlock in interface BlockCachecacheKey - The block's cache key.buf - The object to cache.public Cacheable getBlock(BlockCacheKey cacheKey, boolean caching, boolean repeat, boolean updateCacheMetrics)
BlockCachegetBlock in interface BlockCachecacheKey - Block to fetch.caching - Whether this request has caching enabled (used for stats)repeat - Whether this is a repeat lookup for the same block
(used to avoid double counting cache misses when doing double-check locking)updateCacheMetrics - Whether to update cache metrics or notpublic boolean evictBlock(BlockCacheKey cacheKey)
BlockCacheevictBlock in interface BlockCachecacheKey - Block to evictpublic int evictBlocksByHfileName(String hfileName)
BlockCacheevictBlocksByHfileName in interface BlockCachepublic CacheStats getStats()
BlockCachegetStats in interface BlockCachepublic void shutdown()
BlockCacheshutdown in interface BlockCachepublic long size()
BlockCachesize in interface BlockCachepublic long getFreeSize()
BlockCachegetFreeSize in interface BlockCachepublic long getCurrentSize()
BlockCachegetCurrentSize in interface BlockCachepublic long getBlockCount()
BlockCachegetBlockCount in interface BlockCachepublic Iterator<CachedBlock> iterator()
iterator in interface Iterable<CachedBlock>iterator in interface BlockCachepublic BlockCache[] getBlockCaches()
getBlockCaches in interface BlockCachepublic void setMaxSize(long size)
ResizableBlockCachesetMaxSize in interface ResizableBlockCachesize - The max heap size.Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.