@InterfaceAudience.Private public interface StoreFileManager
Modifier and Type | Method and Description |
---|---|
void |
addCompactionResults(java.util.Collection<StoreFile> compactedFiles,
java.util.Collection<StoreFile> results)
Adds compaction results into the structure.
|
<any> |
clearFiles()
Clears all the files currently in use and returns them.
|
java.util.Iterator<StoreFile> |
getCandidateFilesForRowKeyBefore(KeyValue targetKey)
Gets initial, full list of candidate store files to check for row-key-before.
|
double |
getCompactionPressure() |
java.util.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() |
java.util.Comparator<StoreFile> |
getStoreFileComparator() |
int |
getStorefileCount()
Returns the number of files currently in use.
|
java.util.Collection<StoreFile> |
getStorefiles()
Gets the snapshot of the store files currently in use.
|
java.util.Collection<StoreFile> |
getUnneededFiles(long maxTs,
java.util.List<StoreFile> filesCompacting) |
void |
insertNewFiles(java.util.Collection<StoreFile> sfs)
Adds new files, either for from MemStore flush or bulk insert, into the structure.
|
void |
loadFiles(java.util.List<StoreFile> storeFiles)
Loads the initial store files into empty StoreFileManager.
|
java.util.Iterator<StoreFile> |
updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
void loadFiles(java.util.List<StoreFile> storeFiles)
storeFiles
- The files to load.void insertNewFiles(java.util.Collection<StoreFile> sfs) throws java.io.IOException
sfs
- New store files.java.io.IOException
void addCompactionResults(java.util.Collection<StoreFile> compactedFiles, java.util.Collection<StoreFile> results) throws java.io.IOException
compactedFiles
- The input files for the compaction.results
- The resulting files for the compaction.java.io.IOException
<any> clearFiles()
java.util.Collection<StoreFile> getStorefiles()
int getStorefileCount()
java.util.Collection<StoreFile> getFilesForScanOrGet(boolean isGet, byte[] startRow, byte[] stopRow)
isGet
- Whether it's a get.startRow
- Start row of the request.stopRow
- Stop row of the request.java.util.Iterator<StoreFile> getCandidateFilesForRowKeyBefore(KeyValue targetKey)
targetKey
- The key that is the basis of the search.java.util.Iterator<StoreFile> updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles, KeyValue targetKey, Cell candidate)
candidateFiles
- The candidate files not yet checked for better candidates - return
value from getCandidateFilesForRowKeyBefore(KeyValue)
,
with some files already removed.targetKey
- The key to search for.candidate
- The current best candidate found.byte[] getSplitPoint() throws java.io.IOException
java.io.IOException
int getStoreCompactionPriority()
java.util.Collection<StoreFile> getUnneededFiles(long maxTs, java.util.List<StoreFile> filesCompacting)
maxTs
- Maximum expired timestamp.filesCompacting
- Files that are currently compacting.double getCompactionPressure()
Store.getCompactionPressure()
java.util.Comparator<StoreFile> getStoreFileComparator()
StoreFile.getMaxSequenceId()
is the first priority.