| 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 |
|---|---|
(package private) static List<BucketCache.RAMQueueEntry> |
BucketCache.getRAMQueueEntries(BlockingQueue<BucketCache.RAMQueueEntry> q,
List<BucketCache.RAMQueueEntry> receptical)
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> receptical)
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> receptical)
Blocks until elements available in
q then tries to grab as many as possible
before returning. |
| Constructor and Description |
|---|
BucketCache.WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.