@InterfaceAudience.Private public class HFileReaderV2 extends AbstractHFileReader
HFile
reader for version 2.Modifier and Type | Class and Description |
---|---|
protected static class |
HFileReaderV2.AbstractScannerV2 |
protected static class |
HFileReaderV2.EncodedScannerV2
ScannerV2 that operates on encoded data blocks.
|
protected static class |
HFileReaderV2.ScannerV2
Implementation of
HFileScanner interface. |
AbstractHFileReader.BlockIndexNotLoadedException, AbstractHFileReader.NotSeekedException, AbstractHFileReader.Scanner
avgKeyLen, avgValueLen, cacheConf, comparator, compressAlgo, dataBlockEncoder, dataBlockIndexReader, fileInfo, fileSize, hfs, istream, istreamNoFsChecksum, lastKey, metaBlockIndexReader, name, path, trailer
Constructor and Description |
---|
HFileReaderV2(org.apache.hadoop.fs.Path path,
FixedFileTrailer trailer,
FSDataInputStreamWrapper fsdis,
long size,
CacheConfig cacheConf,
DataBlockEncoding preferredEncodingInCache,
HFileSystem hfs)
Opens a HFile.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
close(boolean evictOnClose)
Close method with optional evictOnClose
|
DataInput |
getDeleteBloomFilterMetadata()
Retrieves delete family Bloom filter metadata as appropriate for each
HFile version. |
DataInput |
getGeneralBloomFilterMetadata()
Returns a buffer with the Bloom filter metadata.
|
byte[] |
getLastKey() |
ByteBuffer |
getMetaBlock(String metaBlockName,
boolean cacheBlock) |
HFileScanner |
getScanner(boolean cacheBlocks,
boolean pread,
boolean isCompaction)
Create a Scanner on this file.
|
boolean |
isFileInfoLoaded() |
byte[] |
midkey() |
HFileBlock |
readBlock(long dataBlockOffset,
long onDiskBlockSize,
boolean cacheBlock,
boolean pread,
boolean isCompaction,
BlockType expectedBlockType)
Read in a file block.
|
getComparator, getCompressionAlgorithm, getDataBlockIndexReader, getEncodingOnDisk, getEntries, getFirstKey, getFirstRowKey, getLastRowKey, getName, getPath, getScanner, getTrailer, indexSize, length, loadFileInfo, toString, toStringFirstKey, toStringLastKey
public HFileReaderV2(org.apache.hadoop.fs.Path path, FixedFileTrailer trailer, FSDataInputStreamWrapper fsdis, long size, CacheConfig cacheConf, DataBlockEncoding preferredEncodingInCache, HFileSystem hfs) throws IOException
AbstractHFileReader.loadFileInfo()
.path
- Path to HFile.trailer
- File trailer.fsdis
- input stream.size
- Length of the stream.cacheConf
- Cache configuration.preferredEncodingInCache
- the encoding to use in cache in case we
have a choice. If the file is already encoded on disk, we will
still use its on-disk encoding in cache.IOException
public HFileScanner getScanner(boolean cacheBlocks, boolean pread, boolean isCompaction)
HFileScanner.seekTo(byte[])
to position an start the read. There is
nothing to clean up in a Scanner. Letting go of your references to the
scanner is sufficient.cacheBlocks
- True if we should cache blocks read in by this scanner.pread
- Use positional read rather than seek+read if true (pread is
better for random reads, seek+read is better scanning).isCompaction
- is scanner being used for a compaction?public ByteBuffer getMetaBlock(String metaBlockName, boolean cacheBlock) throws IOException
metaBlockName
- cacheBlock
- Add block to cache, if foundIOException
public HFileBlock readBlock(long dataBlockOffset, long onDiskBlockSize, boolean cacheBlock, boolean pread, boolean isCompaction, BlockType expectedBlockType) throws IOException
dataBlockOffset
- offset to read.onDiskBlockSize
- size of the blockcacheBlock
- pread
- Use positional read instead of seek+read (positional is
better doing random reads whereas seek+read is better scanning).isCompaction
- is this block being read as part of a compactionexpectedBlockType
- the block type we are expecting to read with this
read operation, or null to read whatever block type is available
and avoid checking (that might reduce caching efficiency of
encoded data blocks)IOException
public byte[] getLastKey()
public byte[] midkey() throws IOException
IOException
public void close() throws IOException
IOException
public void close(boolean evictOnClose) throws IOException
HFile.Reader
IOException
public DataInput getGeneralBloomFilterMetadata() throws IOException
IOException
public DataInput getDeleteBloomFilterMetadata() throws IOException
HFile.Reader
HFile
version.
Knows nothing about how that metadata is structured.IOException
public boolean isFileInfoLoaded()
isFileInfoLoaded
in class AbstractHFileReader
Copyright © 2013 The Apache Software Foundation. All rights reserved.