Package | Description |
---|---|
org.apache.hadoop.hbase.io.hfile |
Provides implementations of
HFile and HFile
BlockCache . |
Modifier and Type | Field and Description |
---|---|
protected HFileBlock |
HFileReaderImpl.HFileScannerImpl.curBlock |
private HFileBlock |
BlockWithScanInfo.hFileBlock |
Modifier and Type | Field and Description |
---|---|
private List<HFileBlock> |
HFileReaderImpl.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 |
MemcachedBlockCache.HFileBlockTranscoder.decode(net.spy.memcached.CachedData d) |
HFileBlock |
HFileBlock.deepClone() |
(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 |
HFileReaderImpl.getMetaBlock(String metaBlockName,
boolean cacheBlock) |
HFileBlock |
HFile.Reader.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 |
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.
|
HFileBlock |
HFileBlock.FSReader.readBlockData(long offset,
long onDiskSize,
boolean pread,
boolean updateMetrics)
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)
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)
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 |
HFileBlockIndex.BlockIndexReader.seekToDataBlock(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding)
Return the data block which contains this key.
|
(package private) HFileBlock |
HFileBlock.unpack(HFileContext fileContext,
HFileBlock.FSReader reader)
Retrieves the decompressed/decrypted view of this block.
|
Modifier and Type | Method and Description |
---|---|
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) |
BlockWithScanInfo |
HFileBlockIndex.CellBasedKeyBlockIndexReader.loadDataBlockWithScanInfo(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding) |
abstract BlockWithScanInfo |
HFileBlockIndex.BlockIndexReader.loadDataBlockWithScanInfo(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding)
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.
|
void |
HFileReaderImpl.returnBlock(HFileBlock block) |
void |
HFile.CachingBlockReader.returnBlock(HFileBlock block)
Return the given block back to the cache, if it was obtained from cache.
|
private void |
HFileReaderImpl.HFileScannerImpl.returnBlockToCache(HFileBlock block) |
HFileBlock |
HFileBlockIndex.BlockIndexReader.seekToDataBlock(Cell key,
HFileBlock currentBlock,
boolean cacheBlocks,
boolean pread,
boolean isCompaction,
DataBlockEncoding expectedDataBlockEncoding)
Return the data block which contains this key.
|
(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) |
HFileBlock(HFileBlock that)
Copy constructor.
|
HFileBlock(HFileBlock that,
boolean bufCopy)
Copy constructor.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.