Package | Description |
---|---|
org.apache.hadoop.hbase.io.hfile |
Provides implementations of
HFile and HFile
BlockCache . |
Modifier and Type | Class and Description |
---|---|
class |
ExclusiveMemHFileBlock
The
ByteBuffAllocator won't allocate pooled heap ByteBuff now; at the same time,
if allocate an off-heap ByteBuff from allocator, then it must be a pooled one. |
class |
SharedMemHFileBlock
The
ByteBuffAllocator won't allocate pooled heap ByteBuff now; at the same time,
if allocate an off-heap ByteBuff from allocator, then it must be a pooled one. |
Modifier and Type | Field and Description |
---|---|
protected HFileBlock |
HFileReaderImpl.HFileScannerImpl.curBlock |
private HFileBlock |
BlockWithScanInfo.hFileBlock |
Modifier and Type | Field and Description |
---|---|
private List<HFileBlock> |
HFileInfo.loadOnOpenBlocks
Blocks read from the load-on-open section, excluding data root index, meta
index, and file info.
|
protected ArrayList<HFileBlock> |
HFileReaderImpl.HFileScannerImpl.prevBlocks |
Modifier and Type | Method and Description |
---|---|
HFileBlock |
HFileBlockBuilder.build() |
(package private) static HFileBlock |
HFileBlock.createFromBuff(ByteBuff buf,
boolean usesHBaseChecksum,
long offset,
int nextBlockOnDiskSize,
HFileContext fileContext,
ByteBuffAllocator allocator)
Creates a block from an existing buffer starting with a header.
|
HFileBlock |
MemcachedBlockCache.HFileBlockTranscoder.decode(net.spy.memcached.CachedData d) |
(package private) static HFileBlock |
HFileBlock.deepCloneOnHeap(HFileBlock blk) |
HFileBlock |
HFileBlock.BlockDeserializer.deserialize(ByteBuff buf,
ByteBuffAllocator alloc) |
(package private) HFileBlock |
HFileBlock.Writer.getBlockForCaching(CacheConfig cacheConf)
Creates a new HFileBlock.
|
private HFileBlock |
CompoundBloomFilter.getBloomBlock(int block) |
private HFileBlock |
HFileReaderImpl.getCachedBlock(BlockCacheKey cacheKey,
boolean cacheBlock,
boolean useLock,
boolean isCompaction,
boolean updateCacheMetrics,
BlockType expectedBlockType,
DataBlockEncoding expectedDataBlockEncoding)
Retrieve block from cache.
|
HFileBlock |
BlockWithScanInfo.getHFileBlock() |
HFileBlock |
HFile.Reader.getMetaBlock(String metaBlockName,
boolean cacheBlock) |
HFileBlock |
HFileReaderImpl.getMetaBlock(String metaBlockName,
boolean cacheBlock) |
HFileBlock |
HFileBlock.BlockIterator.nextBlock()
Get the next block, or null if there are no more blocks to iterate.
|
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 |
HFileBlock.FSReader.readBlockData(long offset,
long onDiskSize,
boolean pread,
boolean updateMetrics,
boolean intoHeap)
Reads the block at the given offset in the file with the given on-disk size and uncompressed
size.
|
HFileBlock |
HFileBlock.FSReaderImpl.readBlockData(long offset,
long onDiskSizeWithHeaderL,
boolean pread,
boolean updateMetrics,
boolean intoHeap)
Reads a version 2 block (version 1 blocks not supported and not expected).
|
protected HFileBlock |
HFileBlock.FSReaderImpl.readBlockDataInternal(org.apache.hadoop.fs.FSDataInputStream is,
long offset,
long onDiskSizeWithHeaderL,
boolean pread,
boolean verifyChecksum,
boolean updateMetrics,
boolean intoHeap)
Reads a version 2 block.
|
protected HFileBlock |
HFileReaderImpl.HFileScannerImpl.readNextDataBlock()
Scans blocks in the "scanned" section of the
HFile until the next
data block is found. |
HFileBlock |
HFileBlock.retain() |
HFileBlock |
HFileBlockIndex.BlockIndexReader.seekToDataBlock(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding,
HFile.CachingBlockReader cachingBlockReader)
Return the data block which contains this key.
|
(package private) static HFileBlock |
HFileBlock.shallowClone(HFileBlock blk) |
(package private) HFileBlock |
HFileBlock.unpack(HFileContext fileContext,
HFileBlock.FSReader reader)
Retrieves the decompressed/decrypted view of this block.
|
Modifier and Type | Method and Description |
---|---|
List<HFileBlock> |
HFileInfo.getLoadOnOpenBlocks() |
Modifier and Type | Method and Description |
---|---|
private static HFileBlockBuilder |
HFileBlock.createBuilder(HFileBlock blk) |
(package private) static HFileBlock |
HFileBlock.deepCloneOnHeap(HFileBlock blk) |
net.spy.memcached.CachedData |
MemcachedBlockCache.HFileBlockTranscoder.encode(HFileBlock block) |
private ByteBuff |
HFileReaderImpl.EncodedScanner.getEncodedBuffer(HFileBlock newBlock) |
protected Cell |
HFileReaderImpl.HFileScannerImpl.getFirstKeyCellInBlock(HFileBlock curBlock) |
protected Cell |
HFileReaderImpl.EncodedScanner.getFirstKeyCellInBlock(HFileBlock curBlock) |
protected int |
HFileReaderImpl.HFileScannerImpl.loadBlockAndSeekToKey(HFileBlock seekToBlock,
Cell nextIndexedKey,
boolean rewind,
Cell key,
boolean seekBefore) |
protected int |
HFileReaderImpl.EncodedScanner.loadBlockAndSeekToKey(HFileBlock seekToBlock,
Cell nextIndexedKey,
boolean rewind,
Cell key,
boolean seekBefore) |
BlockWithScanInfo |
HFileBlockIndex.ByteArrayKeyBlockIndexReader.loadDataBlockWithScanInfo(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding,
HFile.CachingBlockReader cachingBlockReader) |
BlockWithScanInfo |
HFileBlockIndex.CellBasedKeyBlockIndexReader.loadDataBlockWithScanInfo(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding,
HFile.CachingBlockReader cachingBlockReader) |
abstract BlockWithScanInfo |
HFileBlockIndex.BlockIndexReader.loadDataBlockWithScanInfo(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding,
HFile.CachingBlockReader cachingBlockReader)
Return the BlockWithScanInfo, a data structure which contains the Data HFileBlock with
other scan info such as the key that starts the next HFileBlock.
|
void |
HFileBlockIndex.BlockIndexReader.readMultiLevelIndexRoot(HFileBlock blk,
int numEntries)
Read the root-level metadata of a multi-level block index.
|
DataInputStream |
HFileBlockIndex.BlockIndexReader.readRootIndex(HFileBlock blk,
int numEntries)
Read in the root-level index from the given input stream.
|
protected void |
HFileReaderImpl.HFileScannerImpl.releaseIfNotCurBlock(HFileBlock block)
The curBlock will be released by shipping or close method, so only need to consider releasing
the block, which was read from HFile before and not referenced by curBlock.
|
HFileBlock |
HFileBlockIndex.BlockIndexReader.seekToDataBlock(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding,
HFile.CachingBlockReader cachingBlockReader)
Return the data block which contains this key.
|
(package private) static HFileBlock |
HFileBlock.shallowClone(HFileBlock blk) |
(package private) void |
HFileReaderImpl.HFileScannerImpl.updateCurrBlockRef(HFileBlock block) |
protected void |
HFileReaderImpl.HFileScannerImpl.updateCurrentBlock(HFileBlock newBlock)
Updates the current block to be the given
HFileBlock . |
protected void |
HFileReaderImpl.EncodedScanner.updateCurrentBlock(HFileBlock newBlock)
Updates the current block to be the given
HFileBlock . |
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 |
---|
BlockWithScanInfo(HFileBlock hFileBlock,
Cell nextIndexedKey) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.