@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 |
---|---|
private byte[] |
firstKey |
private boolean |
firstKeySeeked |
private static org.apache.commons.logging.Log |
LOG |
protected Cell |
splitCell |
protected byte[] |
splitkey |
(package private) boolean |
top |
bloomFilterType, deleteFamilyBloomFilter, generalBloomFilter, sequenceID, timeRangeTracker
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)
Warning: Do not write further code which depends on this call.
|
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, getStoreFileScanner, getTotalBloomSize, getTotalUncompressedBytes, indexSize, isBulkLoaded, isPrimaryReplicaReader, length, loadBloomfilter, loadFileInfo, passesDeleteFamilyBloomFilter, passesGeneralBloomFilter, setBulkLoaded, setDeleteFamilyBloomFilterFaulty, setGeneralBloomFilterFaulty, setReplicaStoreFile, setSequenceID
private static final org.apache.commons.logging.Log LOG
final boolean top
protected final byte[] splitkey
protected final Cell splitCell
private byte[] firstKey
private boolean firstKeySeeked
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
- ConfigurationIOException
public 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
- FSDataInputStreamWrapper
size
- Full size of the hfile filecacheConf
- r
- original reference file (contains top or bottom)conf
- ConfigurationIOException
protected boolean isTop()
public HFileScanner getScanner(boolean cacheBlocks, boolean pread, boolean isCompaction)
StoreFile.Reader
getScanner
in class StoreFile.Reader
cacheBlocks
- 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.Reader
passesKeyRangeFilter
in class StoreFile.Reader
scan
- the scan specification. Used to determine the rowkey range.public byte[] getLastKey()
getLastKey
in class StoreFile.Reader
public byte[] midkey() throws IOException
midkey
in class StoreFile.Reader
IOException
public byte[] getFirstKey()
getFirstKey
in class StoreFile.Reader
public long getEntries()
getEntries
in class StoreFile.Reader
public long getFilterEntries()
StoreFile.Reader
getFilterEntries
in class StoreFile.Reader
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.