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.
|
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–2019 The Apache Software Foundation. All rights reserved.