| Package | Description |
|---|---|
| org.apache.hadoop.hbase.io.hfile.bucket |
Provides
BucketCache, an implementation of
BlockCache. |
| Modifier and Type | Field and Description |
|---|---|
(package private) ConcurrentMap<BlockCacheKey,BucketCache.BucketEntry> |
BucketCache.backingMap |
(package private) static Comparator<BucketCache.BucketEntry> |
BucketCache.BucketEntry.COMPARATOR |
private com.google.common.collect.MinMaxPriorityQueue<Map.Entry<BlockCacheKey,BucketCache.BucketEntry>> |
CachedEntryQueue.queue |
| Modifier and Type | Method and Description |
|---|---|
BucketCache.BucketEntry |
BucketCache.RAMQueueEntry.writeToCache(IOEngine ioEngine,
BucketAllocator bucketAllocator,
UniqueIndexMap<Integer> deserialiserMap,
AtomicLong realCacheSize) |
| Modifier and Type | Method and Description |
|---|---|
Map.Entry<BlockCacheKey,BucketCache.BucketEntry> |
CachedEntryQueue.poll() |
Map.Entry<BlockCacheKey,BucketCache.BucketEntry> |
CachedEntryQueue.pollLast() |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
BucketCache.blockEvicted(BlockCacheKey cacheKey,
BucketCache.BucketEntry bucketEntry,
boolean decrementBlockNumber) |
| Modifier and Type | Method and Description |
|---|---|
void |
BucketCache.BucketEntryGroup.add(Map.Entry<BlockCacheKey,BucketCache.BucketEntry> block) |
void |
CachedEntryQueue.add(Map.Entry<BlockCacheKey,BucketCache.BucketEntry> entry)
Attempt to add the specified entry to this queue.
|
| Constructor and Description |
|---|
BucketAllocator(long availableSpace,
int[] bucketSizes,
Map<BlockCacheKey,BucketCache.BucketEntry> map,
AtomicLong realCacheSize)
Rebuild the allocator's data structures from a persisted map.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.