org.apache.hadoop.hbase.io.hfile.bucket

Class TestByteBufferIOEngine.MockBucketEntry

java.lang.Object

org.apache.hadoop.hbase.io.hfile.bucket.TestByteBufferIOEngine.MockBucketEntry

All Implemented Interfaces:

org.apache.hadoop.hbase.nio.HBaseReferenceCounted, org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

Enclosing class:

TestByteBufferIOEngine

private static class TestByteBufferIOEngine.MockBucketEntry
extends Object

Override the BucketEntry so that we can set an arbitrary offset.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static interface	org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry.BucketEntryHandler<T>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.hbase.io.ByteBuffAllocator	allocator
(package private) static Comparator<org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry>	COMPARATOR
(package private) byte	deserializerIndex
(package private) AtomicBoolean	markedAsEvicted
private long	off

Constructor Summary

Constructors

Constructor and Description
MockBucketEntry(long offset, int length, org.apache.hadoop.hbase.io.ByteBuffAllocator allocator)

Method Summary

Modifier and Type	Method and Description
(package private) void	access(long arg0)
(package private) org.apache.hadoop.hbase.io.hfile.CacheableDeserializer<org.apache.hadoop.hbase.io.hfile.Cacheable>	deserializerReference()
(package private) long	getAccessCounter()
(package private) long	getCachedTime()
int	getLength()
org.apache.hadoop.hbase.io.hfile.BlockPriority	getPriority()
(package private) boolean	isRpcRef()
(package private) boolean	markAsEvicted()
(package private) long	offset()
int	refCnt()
boolean	release()
org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry	retain()
(package private) void	setDeserializerReference(org.apache.hadoop.hbase.io.hfile.CacheableDeserializer<org.apache.hadoop.hbase.io.hfile.Cacheable> arg0)
(package private) <T> T	withWriteLock(org.apache.hadoop.hbase.util.IdReadWriteLock<Long> arg0, org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry.BucketEntryHandler<T> arg1)
(package private) org.apache.hadoop.hbase.io.hfile.Cacheable	wrapAsCacheable(org.apache.hadoop.hbase.nio.ByteBuff arg0)
(package private) org.apache.hadoop.hbase.io.hfile.Cacheable	wrapAsCacheable(ByteBuffer[] arg0)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.nio.HBaseReferenceCounted

release, retain, touch, touch

Field Detail

off

private long off

COMPARATOR

static final Comparator<org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry> COMPARATOR

deserializerIndex

byte deserializerIndex

markedAsEvicted

final AtomicBoolean markedAsEvicted

allocator

final org.apache.hadoop.hbase.io.ByteBuffAllocator allocator

Constructor Detail

MockBucketEntry

MockBucketEntry(long offset,
                int length,
                org.apache.hadoop.hbase.io.ByteBuffAllocator allocator)

Method Detail

offset

long offset()

getLength

public int getLength()

deserializerReference

org.apache.hadoop.hbase.io.hfile.CacheableDeserializer<org.apache.hadoop.hbase.io.hfile.Cacheable> deserializerReference()

setDeserializerReference

void setDeserializerReference(org.apache.hadoop.hbase.io.hfile.CacheableDeserializer<org.apache.hadoop.hbase.io.hfile.Cacheable> arg0)

getAccessCounter

long getAccessCounter()

access

void access(long arg0)

getPriority

public org.apache.hadoop.hbase.io.hfile.BlockPriority getPriority()

getCachedTime

long getCachedTime()

markAsEvicted

boolean markAsEvicted()

isRpcRef

boolean isRpcRef()

wrapAsCacheable

org.apache.hadoop.hbase.io.hfile.Cacheable wrapAsCacheable(ByteBuffer[] arg0)
                                                    throws IOException

Throws:

IOException

wrapAsCacheable

org.apache.hadoop.hbase.io.hfile.Cacheable wrapAsCacheable(org.apache.hadoop.hbase.nio.ByteBuff arg0)
                                                    throws IOException

Throws:

IOException

withWriteLock

<T> T withWriteLock(org.apache.hadoop.hbase.util.IdReadWriteLock<Long> arg0,
                    org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry.BucketEntryHandler<T> arg1)

refCnt

public int refCnt()

Specified by:

refCnt in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

retain

public org.apache.hadoop.hbase.io.hfile.bucket.BucketEntry retain()

Specified by:

retain in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted

release

public boolean release()

Specified by:

release in interface org.apache.hbase.thirdparty.io.netty.util.ReferenceCounted