@InterfaceAudience.Private public class HalfStoreFileReader extends StoreFile.Reader
HFile.Reader that serves up
either the top or bottom half of a HFile where 'bottom' is the first half
of the file containing the keys that sort lowest and 'top' is the second half
of the file with keys that sort greater than those of the bottom half.
The top includes the split files midkey, of the key that follows if it does
not exist in the file.
This type works in tandem with the Reference type. This class
is used reading while Reference is used writing.
This file is not splitable. Calls to midkey() return null.
| Modifier and Type | Field and Description |
|---|---|
protected Cell |
splitCell |
protected byte[] |
splitkey |
bloomFilterType, deleteFamilyBloomFilter, generalBloomFilter, sequenceID, timeRange| Constructor and Description |
|---|
HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
Creates a half file reader for a normal hfile.
|
HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
Creates a half file reader for a hfile referred to by an hfilelink.
|
| Modifier and Type | Method and Description |
|---|---|
long |
getEntries() |
long |
getFilterEntries()
The number of Bloom filter entries in this store file, or an estimate
thereof, if the Bloom filter is not loaded.
|
byte[] |
getFirstKey() |
byte[] |
getLastKey() |
HFileScanner |
getScanner(boolean cacheBlocks,
boolean pread,
boolean isCompaction) |
protected boolean |
isTop() |
byte[] |
midkey() |
boolean |
passesKeyRangeFilter(Scan scan)
Checks whether the given scan rowkey range overlaps with the current storefile's
|
close, getBloomFilterType, getComparator, getDeleteFamilyCnt, getHFileMinorVersion, getHFileReader, getHFileVersion, getLastRowKey, getMaxTimestamp, getScanner, getSequenceID, getStoreFileScanner, getTotalBloomSize, getTotalUncompressedBytes, indexSize, isBulkLoaded, isCompactedAway, isPrimaryReplicaReader, isReferencedInReads, length, loadBloomfilter, loadFileInfo, passesDeleteFamilyBloomFilter, passesGeneralBloomFilter, setBulkLoaded, setDeleteFamilyBloomFilterFaulty, setGeneralBloomFilterFaulty, setReplicaStoreFile, setSequenceIDprotected final byte[] splitkey
protected final Cell splitCell
public HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
throws IOException
fs - fileystem to read fromp - path to hfilecacheConf - r - original reference file (contains top or bottom)conf - ConfigurationIOExceptionpublic HalfStoreFileReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path p,
FSDataInputStreamWrapper in,
long size,
CacheConfig cacheConf,
Reference r,
org.apache.hadoop.conf.Configuration conf)
throws IOException
fs - fileystem to read fromp - path to hfilein - FSDataInputStreamWrappersize - Full size of the hfile filecacheConf - r - original reference file (contains top or bottom)conf - ConfigurationIOExceptionprotected boolean isTop()
public HFileScanner getScanner(boolean cacheBlocks, boolean pread, boolean isCompaction)
getScanner in class StoreFile.ReadercacheBlocks - should we cache the blocks?pread - use pread (for concurrent small readers)isCompaction - is scanner being used for compaction?public boolean passesKeyRangeFilter(Scan scan)
StoreFile.ReaderpassesKeyRangeFilter in class StoreFile.Readerscan - the scan specification. Used to determine the rowkey range.public byte[] getLastKey()
getLastKey in class StoreFile.Readerpublic byte[] midkey()
throws IOException
midkey in class StoreFile.ReaderIOExceptionpublic byte[] getFirstKey()
getFirstKey in class StoreFile.Readerpublic long getEntries()
getEntries in class StoreFile.Readerpublic long getFilterEntries()
StoreFile.ReadergetFilterEntries in class StoreFile.ReaderCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.