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 |
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,
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.
|
private static HFileBlock |
HFileBlock.shallowClone(HFileBlock blk,
ByteBuff newBuf) |
HFileBlock |
HFileBlock.touch()
Calling this method in strategic locations where HFileBlocks are referenced may help diagnose
potential buffer leaks.
|
HFileBlock |
HFileBlock.touch(Object hint) |
(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,
ByteBuff newBuff)
Creates a new HFileBlockBuilder from the existing block and a new ByteBuff.
|
(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.
|
private static HFileBlock |
HFileBlock.shallowClone(HFileBlock blk,
ByteBuff newBuf) |
(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.