Field Detail

• generalBloomFilter

  protected BloomFilter generalBloomFilter

• deleteFamilyBloomFilter

  protected BloomFilter deleteFamilyBloomFilter

• bloomFilterType

  protected BloomType bloomFilterType

• timeRange

  protected TimeRange timeRange

• sequenceID

  protected long sequenceID

Constructor Detail

• StoreFile.Reader

  public StoreFile.Reader(org.apache.hadoop.fs.FileSystem fs,
                  org.apache.hadoop.fs.Path path,
                  CacheConfig cacheConf,
                  org.apache.hadoop.conf.Configuration conf)
                   throws IOException

  Throws:

  IOException

• StoreFile.Reader

  public StoreFile.Reader(org.apache.hadoop.fs.FileSystem fs,
                  org.apache.hadoop.fs.Path path,
                  FSDataInputStreamWrapper in,
                  long size,
                  CacheConfig cacheConf,
                  org.apache.hadoop.conf.Configuration conf)
                   throws IOException

  Throws:

  IOException

Method Detail

• setReplicaStoreFile

  public void setReplicaStoreFile(boolean isPrimaryReplicaStoreFile)

• isPrimaryReplicaReader

  public boolean isPrimaryReplicaReader()

• getComparator

  public KeyValue.KVComparator getComparator()

• getStoreFileScanner

  public StoreFileScanner getStoreFileScanner(boolean cacheBlocks,
                                     boolean pread,
                                     boolean isCompaction,
                                     long readPt,
                                     long scannerOrder,
                                     boolean canOptimizeForNonNullColumn)

  Get a scanner to scan over this StoreFile.

  Parameters:

  cacheBlocks - should this scanner cache blocks?

  pread - use pread (for highly concurrent small readers)

  isCompaction - is scanner being used for compaction?

  scannerOrder - Order of this scanner relative to other scanners. See KeyValueScanner.getScannerOrder().

  canOptimizeForNonNullColumn - true if we can make sure there is no null column, otherwise false. This is a hint for optimization.

  Returns:

  a scanner

• isReferencedInReads

  public boolean isReferencedInReads()

  Returns:

  true if the file is still used in reads

• isCompactedAway

  public boolean isCompactedAway()

  Returns:

  true if the file is compacted

• getScanner

  @Deprecated
  public HFileScanner getScanner(boolean cacheBlocks,
                                   boolean pread)

  Deprecated. Do not write further code which depends on this call. Instead use getStoreFileScanner() which uses the StoreFileScanner class/interface which is the preferred way to scan a store with higher level concepts.

  Parameters:

  cacheBlocks - should we cache the blocks?

  pread - use pread (for concurrent small readers)

  Returns:

  the underlying HFileScanner

• getScanner

  @Deprecated
  public HFileScanner getScanner(boolean cacheBlocks,
                                   boolean pread,
                                   boolean isCompaction)

  Deprecated. Do not write further code which depends on this call. Instead use getStoreFileScanner() which uses the StoreFileScanner class/interface which is the preferred way to scan a store with higher level concepts.

  Parameters:

  cacheBlocks - should we cache the blocks?

  pread - use pread (for concurrent small readers)

  isCompaction - is scanner being used for compaction?

  Returns:

  the underlying HFileScanner

• close

  public void close(boolean evictOnClose)
             throws IOException

  Throws:

  IOException

• passesDeleteFamilyBloomFilter

  public boolean passesDeleteFamilyBloomFilter(byte[] row,
                                      int rowOffset,
                                      int rowLen)

• passesGeneralBloomFilter

  public boolean passesGeneralBloomFilter(byte[] row,
                                 int rowOffset,
                                 int rowLen,
                                 byte[] col,
                                 int colOffset,
                                 int colLen)

  A method for checking Bloom filters. Called directly from StoreFileScanner in case of a multi-column query.

  Parameters:

  row -

  rowOffset -

  rowLen -

  col -

  colOffset -

  colLen -

  Returns:

  True if passes

• passesKeyRangeFilter

  public boolean passesKeyRangeFilter(Scan scan)

  Checks whether the given scan rowkey range overlaps with the current storefile's

  Parameters:

  scan - the scan specification. Used to determine the rowkey range.

  Returns:

  true if there is overlap, false otherwise

• loadFileInfo

  public Map<byte[],byte[]> loadFileInfo()
                                  throws IOException

  Throws:

  IOException

• loadBloomfilter

  public void loadBloomfilter()

• getFilterEntries

  public long getFilterEntries()

  The number of Bloom filter entries in this store file, or an estimate thereof, if the Bloom filter is not loaded. This always returns an upper bound of the number of Bloom filter entries.

  Returns:

  an estimate of the number of Bloom filter entries in this file

• setGeneralBloomFilterFaulty

  public void setGeneralBloomFilterFaulty()

• setDeleteFamilyBloomFilterFaulty

  public void setDeleteFamilyBloomFilterFaulty()

• getLastKey

  public byte[] getLastKey()

• getLastRowKey

  public byte[] getLastRowKey()

• midkey

  public byte[] midkey()
                throws IOException

  Throws:

  IOException

• length

  public long length()

• getTotalUncompressedBytes

  public long getTotalUncompressedBytes()

• getEntries

  public long getEntries()

• getDeleteFamilyCnt

  public long getDeleteFamilyCnt()

• getFirstKey

  public byte[] getFirstKey()

• indexSize

  public long indexSize()

• getBloomFilterType

  public BloomType getBloomFilterType()

• getSequenceID

  public long getSequenceID()

• setSequenceID

  public void setSequenceID(long sequenceID)

• setBulkLoaded

  public void setBulkLoaded(boolean bulkLoadResult)

• isBulkLoaded

  public boolean isBulkLoaded()

• getTotalBloomSize

  public long getTotalBloomSize()

• getHFileVersion

  public int getHFileVersion()

• getHFileMinorVersion

  public int getHFileMinorVersion()

• getHFileReader

  public HFile.Reader getHFileReader()

• getMaxTimestamp

  public long getMaxTimestamp()