Uses of Class
org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry

Packages that use BucketCache.RAMQueueEntry

Package	Description
org.apache.hadoop.hbase.io.hfile.bucket	Provides BucketCache, an implementation of BlockCache.

Uses of BucketCache.RAMQueueEntry in org.apache.hadoop.hbase.io.hfile.bucket

Fields in org.apache.hadoop.hbase.io.hfile.bucket with type parameters of type BucketCache.RAMQueueEntry

Modifier and Type	Field and Description
(package private) ConcurrentHashMap<BlockCacheKey,BucketCache.RAMQueueEntry>	BucketCache.RAMCache.delegate Defined the map as ConcurrentHashMap explicitly here, because in BucketCache.RAMCache.get(BlockCacheKey) and BucketCache.RAMCache.putIfAbsent(BlockCacheKey, BucketCache.RAMQueueEntry) , we need to guarantee the atomicity of map#computeIfPresent(key, func) and map#putIfAbsent(key, func).
private BlockingQueue<BucketCache.RAMQueueEntry>	BucketCache.WriterThread.inputQueue
(package private) ArrayList<BlockingQueue<BucketCache.RAMQueueEntry>>	BucketCache.writerQueues A list of writer queues.

Methods in org.apache.hadoop.hbase.io.hfile.bucket that return BucketCache.RAMQueueEntry

Modifier and Type	Method and Description
BucketCache.RAMQueueEntry	BucketCache.RAMCache.get(BlockCacheKey key)
BucketCache.RAMQueueEntry	BucketCache.RAMCache.putIfAbsent(BlockCacheKey key, BucketCache.RAMQueueEntry entry) Return the previous associated value, or null if absent.

Methods in org.apache.hadoop.hbase.io.hfile.bucket that return types with arguments of type BucketCache.RAMQueueEntry

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.

Methods in org.apache.hadoop.hbase.io.hfile.bucket with parameters of type BucketCache.RAMQueueEntry

Modifier and Type	Method and Description
BucketCache.RAMQueueEntry	BucketCache.RAMCache.putIfAbsent(BlockCacheKey key, BucketCache.RAMQueueEntry entry) Return the previous associated value, or null if absent.

Method parameters in org.apache.hadoop.hbase.io.hfile.bucket with type arguments of type BucketCache.RAMQueueEntry

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.
boolean	BucketCache.RAMCache.remove(BlockCacheKey key, Consumer<BucketCache.RAMQueueEntry> action) Defined an Consumer here, because once the removed entry release its reference count, then it's ByteBuffers may be recycled and accessing it outside this method will be thrown an exception.

Constructor parameters in org.apache.hadoop.hbase.io.hfile.bucket with type arguments of type BucketCache.RAMQueueEntry

Constructor and Description
WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue)