DefaultStoreFileManager (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager

All Implemented Interfaces:: StoreFileManager

@InterfaceAudience.Private
 class DefaultStoreFileManager
extends Object
implements StoreFileManager

Default implementation of StoreFileManager. Not thread-safe.

Field Summary

Fields
Modifier and Type	Field and Description
`private int`	`blockingFileCount`
`private CompactionConfiguration`	`comConf`
`private KeyValue.KVComparator`	`kvComparator`
`private static org.apache.commons.logging.Log`	`LOG`
`private com.google.common.collect.ImmutableList<StoreFile>`	`storefiles` List of store files inside this store.

Constructor Summary

Constructors
Constructor and Description
`DefaultStoreFileManager(KeyValue.KVComparator kvComparator, org.apache.hadoop.conf.Configuration conf, CompactionConfiguration comConf)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addCompactionResults(Collection<StoreFile> compactedFiles, Collection<StoreFile> results)` Adds compaction results into the structure.
`com.google.common.collect.ImmutableCollection<StoreFile>`	`clearFiles()` Clears all the files currently in use and returns them.
`Iterator<StoreFile>`	`getCandidateFilesForRowKeyBefore(KeyValue targetKey)` Gets initial, full list of candidate store files to check for row-key-before.
`double`	`getCompactionPressure()`
`Collection<StoreFile>`	`getFilesForScanOrGet(boolean isGet, byte[] startRow, byte[] stopRow)` Gets the store files to scan for a Scan or Get request.
`byte[]`	`getSplitPoint()` Gets the split point for the split of this set of store files (approx.
`int`	`getStoreCompactionPriority()`
`int`	`getStorefileCount()` Returns the number of files currently in use.
`Collection<StoreFile>`	`getStorefiles()` Gets the snapshot of the store files currently in use.
`Collection<StoreFile>`	`getUnneededFiles(long maxTs, List<StoreFile> filesCompacting)`
`void`	`insertNewFiles(Collection<StoreFile> sfs)` Adds new files, either for from MemStore flush or bulk insert, into the structure.
`void`	`loadFiles(List<StoreFile> storeFiles)` Loads the initial store files into empty StoreFileManager.
`private void`	`sortAndSetStoreFiles(List<StoreFile> storeFiles)`
`Iterator<StoreFile>`	`updateCandidateFilesForRowKeyBefore(Iterator<StoreFile> candidateFiles, KeyValue targetKey, Cell candidate)` Updates the candidate list for finding row key before.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - LOG
```
private static final org.apache.commons.logging.Log LOG
```
  - kvComparator
```
private final KeyValue.KVComparator kvComparator
```
  - comConf
```
private final CompactionConfiguration comConf
```
  - blockingFileCount
```
private final int blockingFileCount
```
  - storefiles
```
private volatile com.google.common.collect.ImmutableList<StoreFile> storefiles
```
    List of store files inside this store. This is an immutable list that is atomically replaced when its contents change.
- Constructor Detail
  - DefaultStoreFileManager
```
public DefaultStoreFileManager(KeyValue.KVComparator kvComparator,
                       org.apache.hadoop.conf.Configuration conf,
                       CompactionConfiguration comConf)
```
- Method Detail
  - loadFiles
```
public void loadFiles(List<StoreFile> storeFiles)
```
    Description copied from interface: StoreFileManager
    
    Loads the initial store files into empty StoreFileManager.
    
    Specified by:
    
    loadFiles in interface StoreFileManager
    
    Parameters:
    storeFiles - The files to load.
  - getStorefiles
```
public final Collection<StoreFile> getStorefiles()
```
    Description copied from interface: StoreFileManager
    
    Gets the snapshot of the store files currently in use. Can be used for things like metrics and checks; should not assume anything about relations between store files in the list.
    
    Specified by:
    
    getStorefiles in interface StoreFileManager
    
    Returns:
    The list of StoreFiles.
  - insertNewFiles
```
public void insertNewFiles(Collection<StoreFile> sfs)
                    throws IOException
```
    Description copied from interface: StoreFileManager
    
    Adds new files, either for from MemStore flush or bulk insert, into the structure.
    
    Specified by:
    
    insertNewFiles in interface StoreFileManager
    
    Parameters:
    sfs - New store files.
    
    Throws:
    
    IOException
  - clearFiles
```
public com.google.common.collect.ImmutableCollection<StoreFile> clearFiles()
```
    Description copied from interface: StoreFileManager
    
    Clears all the files currently in use and returns them.
    
    Specified by:
    
    clearFiles in interface StoreFileManager
    
    Returns:
    The files previously in use.
  - getStorefileCount
```
public final int getStorefileCount()
```
    Description copied from interface: StoreFileManager
    
    Returns the number of files currently in use.
    
    Specified by:
    
    getStorefileCount in interface StoreFileManager
    
    Returns:
    The number of files.
  - addCompactionResults
```
public void addCompactionResults(Collection<StoreFile> compactedFiles,
                        Collection<StoreFile> results)
```
    Description copied from interface: StoreFileManager
    
    Adds compaction results into the structure.
    
    Specified by:
    
    addCompactionResults in interface StoreFileManager
    
    Parameters:
    compactedFiles - The input files for the compaction.
    results - The resulting files for the compaction.
  - getCandidateFilesForRowKeyBefore
```
public final Iterator<StoreFile> getCandidateFilesForRowKeyBefore(KeyValue targetKey)
```
    Description copied from interface: StoreFileManager
    
    Gets initial, full list of candidate store files to check for row-key-before.
    
    Specified by:
    
    getCandidateFilesForRowKeyBefore in interface StoreFileManager
    
    Parameters:
    targetKey - The key that is the basis of the search.
    
    Returns:
    The files that may have the key less than or equal to targetKey, in reverse order of new-ness, and preference for target key.
  - updateCandidateFilesForRowKeyBefore
```
public Iterator<StoreFile> updateCandidateFilesForRowKeyBefore(Iterator<StoreFile> candidateFiles,
                                                      KeyValue targetKey,
                                                      Cell candidate)
```
    Description copied from interface: StoreFileManager
    
    Updates the candidate list for finding row key before. Based on the list of candidates remaining to check from getCandidateFilesForRowKeyBefore, targetKey and current candidate, may trim and reorder the list to remove the files where a better candidate cannot be found.
    
    Specified by:
    
    updateCandidateFilesForRowKeyBefore in interface StoreFileManager
    
    Parameters:
    candidateFiles - The candidate files not yet checked for better candidates - return value from StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue), with some files already removed.
    targetKey - The key to search for.
    candidate - The current best candidate found.
    
    Returns:
    The list to replace candidateFiles.
  - getSplitPoint
```
public final byte[] getSplitPoint()
                           throws IOException
```
    Description copied from interface: StoreFileManager
    
    Gets the split point for the split of this set of store files (approx. middle).
    
    Specified by:
    
    getSplitPoint in interface StoreFileManager
    
    Returns:
    The mid-point, or null if no split is possible.
    
    Throws:
    
    IOException
  - getFilesForScanOrGet
```
public final Collection<StoreFile> getFilesForScanOrGet(boolean isGet,
                                         byte[] startRow,
                                         byte[] stopRow)
```
    Description copied from interface: StoreFileManager
    
    Gets the store files to scan for a Scan or Get request.
    
    Specified by:
    
    getFilesForScanOrGet in interface StoreFileManager
    
    Parameters:
    isGet - Whether it's a get.
    startRow - Start row of the request.
    stopRow - Stop row of the request.
    
    Returns:
    The list of files that are to be read for this request.
  - getStoreCompactionPriority
```
public int getStoreCompactionPriority()
```
    Specified by:
    
    getStoreCompactionPriority in interface StoreFileManager
    
    Returns:
    The store compaction priority.
  - getUnneededFiles
```
public Collection<StoreFile> getUnneededFiles(long maxTs,
                                     List<StoreFile> filesCompacting)
```
    Specified by:
    
    getUnneededFiles in interface StoreFileManager
    
    Parameters:
    maxTs - Maximum expired timestamp.
    filesCompacting - Files that are currently compacting.
    
    Returns:
    The files which don't have any necessary data according to TTL and other criteria.
  - sortAndSetStoreFiles
```
private void sortAndSetStoreFiles(List<StoreFile> storeFiles)
```
  - getCompactionPressure
```
public double getCompactionPressure()
```
    Specified by:
    
    getCompactionPressure in interface StoreFileManager
    
    Returns:
    the compaction pressure used for compaction throughput tuning.
    See Also:
    Store.getCompactionPressure()

Class DefaultStoreFileManager

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

kvComparator

comConf

blockingFileCount

storefiles

Constructor Detail

DefaultStoreFileManager

Method Detail

loadFiles

getStorefiles

insertNewFiles

clearFiles

getStorefileCount

addCompactionResults

getCandidateFilesForRowKeyBefore

updateCandidateFilesForRowKeyBefore

getSplitPoint

getFilesForScanOrGet

getStoreCompactionPriority

getUnneededFiles

sortAndSetStoreFiles

getCompactionPressure