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.regionserver |
Modifier and Type | Field and Description |
---|---|
private BlockType |
HFileBlockDefaultEncodingContext.blockType |
Modifier and Type | Method and Description |
---|---|
BlockType |
HFileBlockEncodingContext.getBlockType() |
BlockType |
HFileBlockDefaultEncodingContext.getBlockType() |
Modifier and Type | Method and Description |
---|---|
void |
HFileBlockEncodingContext.postEncoding(BlockType blockType)
Do any action that needs to be performed after the encoding.
|
void |
HFileBlockDefaultEncodingContext.postEncoding(BlockType blockType) |
Modifier and Type | Field and Description |
---|---|
private BlockType |
BlockCacheKey.blockType |
private BlockType |
HFileBlock.blockType
Type of block.
|
private BlockType |
HFileBlock.Writer.blockType
Current block type.
|
Modifier and Type | Method and Description |
---|---|
BlockType |
CachedBlock.getBlockType() |
BlockType |
BlockCacheKey.getBlockType() |
BlockType |
Cacheable.getBlockType() |
BlockType |
HFileBlock.getBlockType() |
BlockType |
HFileBlock.BlockWritable.getBlockType()
The type of block this data should use.
|
BlockType |
HFileBlockIndex.BlockIndexWriter.getInlineBlockType() |
BlockType |
CompoundBloomFilterWriter.getInlineBlockType() |
BlockType |
InlineBlockWriter.getInlineBlockType()
The type of blocks this block writer produces.
|
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 |
---|---|
(package private) Map<BlockType,Integer> |
LruBlockCache.getBlockTypeCountsForTest() |
Modifier and Type | Method and Description |
---|---|
private void |
HFileWriterImpl.addBloomFilter(BloomFilterWriter bfw,
BlockType blockType) |
void |
NoOpDataBlockEncoder.endBlockEncoding(HFileBlockEncodingContext encodingCtx,
DataOutputStream out,
byte[] uncompressedBytesWithHeader,
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) |
private DataInput |
HFileReaderImpl.getBloomFilterMetadata(BlockType blockType) |
private HFileBlock |
HFileReaderImpl.getCachedBlock(BlockCacheKey cacheKey,
boolean cacheBlock,
boolean useLock,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding)
Retrieve block from cache.
|
void |
CacheStats.hit(boolean caching,
boolean primary,
BlockType type) |
private void |
HFileBlock.init(BlockType blockType,
int onDiskSizeWithoutHeader,
int uncompressedSizeWithoutHeader,
long prevBlockOffset,
long offset,
int onDiskDataSizeWithHeader,
int nextBlockOnDiskSize,
HFileContext fileContext)
Called from constructors.
|
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 |
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)
Read in a file block.
|
private void |
HFileBlock.sanityCheckAssertion(BlockType valueFromBuf,
BlockType valueFromField) |
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.
|
(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.
|
Constructor and Description |
---|
BlockCacheKey(String hfileName,
long offset,
boolean isPrimaryReplica,
BlockType blockType) |
HFileBlock(BlockType blockType,
int onDiskSizeWithoutHeader,
int uncompressedSizeWithoutHeader,
long prevBlockOffset,
ByteBuffer b,
boolean fillHeader,
long offset,
int nextBlockOnDiskSize,
int onDiskDataSizeWithHeader,
HFileContext fileContext)
Creates a new
HFile block from the given fields. |
Modifier and Type | Method and Description |
---|---|
void |
StoreFileReader.loadBloomfilter(BlockType blockType) |
private void |
StoreFileReader.setBloomFilterFaulty(BlockType blockType) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.