@InterfaceAudience.Private public interface BlockCache extends Iterable<CachedBlock>
Cacheable
interface can be put in the cache.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.
|
Iterator<CachedBlock> |
iterator() |
void |
shutdown()
Shutdown the cache.
|
long |
size()
Returns the total size of the block cache, in bytes.
|
void cacheBlock(BlockCacheKey cacheKey, Cacheable buf, boolean inMemory, boolean cacheDataInL1)
cacheKey
- 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).void cacheBlock(BlockCacheKey cacheKey, Cacheable buf)
cacheKey
- The block's cache key.buf
- The object to cache.Cacheable getBlock(BlockCacheKey cacheKey, boolean caching, boolean repeat, boolean updateCacheMetrics)
cacheKey
- 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 notboolean evictBlock(BlockCacheKey cacheKey)
cacheKey
- Block to evictint evictBlocksByHfileName(String hfileName)
CacheStats getStats()
void shutdown()
long size()
long getFreeSize()
long getCurrentSize()
long getBlockCount()
Iterator<CachedBlock> iterator()
iterator
in interface Iterable<CachedBlock>
BlockCache[] getBlockCaches()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.