Package | Description |
---|---|
org.apache.hadoop.hbase.io.hfile.bucket |
Provides
BucketCache , an implementation of
BlockCache . |
Modifier and Type | Field and Description |
---|---|
private BlockingQueue<BucketCache.RAMQueueEntry> |
BucketCache.WriterThread.inputQueue |
(package private) ConcurrentMap<BlockCacheKey,BucketCache.RAMQueueEntry> |
BucketCache.ramCache |
(package private) ArrayList<BlockingQueue<BucketCache.RAMQueueEntry>> |
BucketCache.writerQueues
A list of writer queues.
|
Modifier and Type | Method and Description |
---|---|
private BucketCache.RAMQueueEntry |
BucketCache.checkRamCache(BlockCacheKey cacheKey) |
Modifier and Type | Method and Description |
---|---|
(package private) static List<BucketCache.RAMQueueEntry> |
BucketCache.getRAMQueueEntries(BlockingQueue<BucketCache.RAMQueueEntry> q,
List<BucketCache.RAMQueueEntry> receptacle)
Blocks until elements available in
q then tries to grab as many as possible
before returning. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
BucketCache.WriterThread.doDrain(List<BucketCache.RAMQueueEntry> entries)
Flush the entries in ramCache to IOEngine and add bucket entry to backingMap.
|
(package private) static List<BucketCache.RAMQueueEntry> |
BucketCache.getRAMQueueEntries(BlockingQueue<BucketCache.RAMQueueEntry> q,
List<BucketCache.RAMQueueEntry> receptacle)
Blocks until elements available in
q then tries to grab as many as possible
before returning. |
(package private) static List<BucketCache.RAMQueueEntry> |
BucketCache.getRAMQueueEntries(BlockingQueue<BucketCache.RAMQueueEntry> q,
List<BucketCache.RAMQueueEntry> receptacle)
Blocks until elements available in
q then tries to grab as many as possible
before returning. |
Constructor and Description |
---|
WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.