Package | Description |
---|---|
org.apache.hadoop.hbase.io.encoding | |
org.apache.hadoop.hbase.io.hfile |
Provides implementations of
HFile and HFile
BlockCache . |
org.apache.hadoop.hbase.io.hfile.bucket |
Provides
BucketCache , an implementation of
BlockCache . |
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Field and Description |
---|---|
private BlockType |
HFileBlockDefaultEncodingContext.blockType |
Modifier and Type | Method and Description |
---|---|
BlockType |
HFileBlockDefaultEncodingContext.getBlockType() |
BlockType |
HFileBlockEncodingContext.getBlockType()
Returns the block type after encoding
|
Modifier and Type | Method and Description |
---|---|
void |
HFileBlockDefaultEncodingContext.postEncoding(BlockType blockType) |
void |
HFileBlockEncodingContext.postEncoding(BlockType blockType)
Do any action that needs to be performed after the encoding.
|
Modifier and Type | Field and Description |
---|---|
private BlockType |
HFileBlock.blockType
Type of block.
|
private BlockType |
HFileBlock.Writer.blockType
Current block type.
|
private BlockType |
HFileBlockBuilder.blockType |
private BlockType |
BlockCacheKey.blockType |
Modifier and Type | Method and Description |
---|---|
BlockType |
CachedBlock.getBlockType() |
BlockType |
HFileBlock.getBlockType() |
BlockType |
HFileBlock.BlockWritable.getBlockType()
The type of block this data should use.
|
BlockType |
TinyLfuBlockCache.CachedBlockView.getBlockType() |
BlockType |
BlockCacheKey.getBlockType() |
BlockType |
Cacheable.getBlockType()
Returns the block type of this cached HFile block
|
BlockType |
InlineBlockWriter.getInlineBlockType()
The type of blocks this block writer produces.
|
BlockType |
HFileBlockIndex.BlockIndexWriter.getInlineBlockType() |
BlockType |
CompoundBloomFilterWriter.getInlineBlockType() |
static BlockType |
BlockType.parse(byte[] buf,
int offset,
int length) |
static BlockType |
BlockType.read(ByteBuff buf) |
static BlockType |
BlockType.read(DataInputStream in) |
static BlockType |
BlockType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BlockType[] |
BlockType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
private void |
HFileWriterImpl.addBloomFilter(BloomFilterWriter bfw,
BlockType blockType) |
void |
HFileDataBlockEncoder.endBlockEncoding(HFileBlockEncodingContext encodingCtx,
DataOutputStream out,
byte[] uncompressedBytesWithHeader,
BlockType blockType)
Ends encoding for a block of KeyValues.
|
void |
HFileDataBlockEncoderImpl.endBlockEncoding(HFileBlockEncodingContext encodingCtx,
DataOutputStream out,
byte[] uncompressedBytesWithHeader,
BlockType blockType) |
void |
NoOpDataBlockEncoder.endBlockEncoding(HFileBlockEncodingContext encodingCtx,
DataOutputStream out,
byte[] uncompressedBytesWithHeader,
BlockType blockType) |
Cacheable |
CombinedBlockCache.getBlock(BlockCacheKey cacheKey,
boolean caching,
boolean repeat,
boolean updateCacheMetrics,
BlockType blockType) |
default Cacheable |
BlockCache.getBlock(BlockCacheKey cacheKey,
boolean caching,
boolean repeat,
boolean updateCacheMetrics,
BlockType blockType)
Fetch block from cache.
|
private DataInput |
HFileReaderImpl.getBloomFilterMetadata(BlockType blockType) |
private HFileBlock |
HFileReaderImpl.getCachedBlock(BlockCacheKey cacheKey,
boolean cacheBlock,
boolean useLock,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding)
Retrieve block from cache.
|
void |
CacheStats.hit(boolean caching,
boolean primary,
BlockType type) |
default boolean |
BlockCache.isMetaBlock(BlockType blockType)
Check if block type is meta or index block
|
void |
CacheStats.miss(boolean caching,
boolean primary,
BlockType type) |
HFileBlock |
HFileBlock.BlockIterator.nextBlockWithBlockType(BlockType blockType)
Similar to
HFileBlock.BlockIterator.nextBlock() but checks block type, throws an exception if incorrect, and
returns the HFile block |
HFileBlock |
HFile.CachingBlockReader.readBlock(long offset,
long onDiskBlockSize,
boolean cacheBlock,
boolean pread,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding)
Read in a file block.
|
HFileBlock |
HFileReaderImpl.readBlock(long dataBlockOffset,
long onDiskBlockSize,
boolean cacheBlock,
boolean pread,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding) |
HFileBlock |
HFile.CachingBlockReader.readBlock(long offset,
long onDiskBlockSize,
boolean cacheBlock,
boolean pread,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding,
boolean cacheOnly) |
HFileBlock |
HFileReaderImpl.readBlock(long dataBlockOffset,
long onDiskBlockSize,
boolean cacheBlock,
boolean pread,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding,
boolean cacheOnly) |
private void |
HFileBlock.sanityCheckAssertion(BlockType valueFromBuf,
BlockType valueFromField) |
void |
BlockCacheKey.setBlockType(BlockType blockType) |
boolean |
CacheConfig.shouldLockOnCacheMiss(BlockType blockType)
If we make sure the block could not be cached, we will not acquire the lock otherwise we will
acquire lock
|
boolean |
CacheConfig.shouldReadBlockFromCache(BlockType blockType)
Return true if we may find this type of block in block cache.
|
private boolean |
HFileReaderImpl.shouldUseHeap(BlockType expectedBlockType,
boolean cacheBlock)
Whether we use heap or not depends on our intent to cache the block.
|
(package private) DataOutputStream |
HFileBlock.Writer.startWriting(BlockType newBlockType)
Starts writing into the block.
|
private void |
HFileReaderImpl.validateBlockType(HFileBlock block,
BlockType expectedBlockType)
Compares the actual type of a block retrieved from cache or disk with its expected type and
throws an exception in case of a mismatch.
|
HFileBlockBuilder |
HFileBlockBuilder.withBlockType(BlockType blockType) |
Constructor and Description |
---|
BlockCacheKey(org.apache.hadoop.fs.Path hfilePath,
long offset,
boolean isPrimaryReplica,
BlockType blockType) |
BlockCacheKey(String hfileName,
long offset,
boolean isPrimaryReplica,
BlockType blockType) |
ExclusiveMemHFileBlock(BlockType blockType,
int onDiskSizeWithoutHeader,
int uncompressedSizeWithoutHeader,
long prevBlockOffset,
ByteBuff buf,
boolean fillHeader,
long offset,
int nextBlockOnDiskSize,
int onDiskDataSizeWithHeader,
HFileContext fileContext,
ByteBuffAllocator alloc) |
HFileBlock(BlockType blockType,
int onDiskSizeWithoutHeader,
int uncompressedSizeWithoutHeader,
long prevBlockOffset,
ByteBuff buf,
boolean fillHeader,
long offset,
int nextBlockOnDiskSize,
int onDiskDataSizeWithHeader,
HFileContext fileContext,
ByteBuffAllocator allocator)
Creates a new
HFile block from the given fields. |
SharedMemHFileBlock(BlockType blockType,
int onDiskSizeWithoutHeader,
int uncompressedSizeWithoutHeader,
long prevBlockOffset,
ByteBuff buf,
boolean fillHeader,
long offset,
int nextBlockOnDiskSize,
int onDiskDataSizeWithHeader,
HFileContext fileContext,
ByteBuffAllocator alloc) |
Modifier and Type | Method and Description |
---|---|
private static BlockType |
BucketProtoUtils.fromPb(org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType blockType) |
Modifier and Type | Method and Description |
---|---|
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType |
BucketProtoUtils.toPB(BlockType blockType) |
Modifier and Type | Method and Description |
---|---|
void |
StoreFileReader.loadBloomfilter(BlockType blockType,
BloomFilterMetrics metrics) |
(package private) void |
StoreFileReader.setBloomFilterFaulty(BlockType blockType) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.