@InterfaceAudience.Private public interface StoreFileManager
| Modifier and Type | Method and Description | 
|---|---|
| void | addCompactionResults(Collection<StoreFile> compactedFiles,
                    Collection<StoreFile> results)Adds only the new compaction results into the structure. | 
| Collection<StoreFile> | clearCompactedFiles()Clears all the compacted files and returns them. | 
| 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. | 
| Collection<StoreFile> | getCompactedfiles()List of compacted files inside this store that needs to be excluded in reads
 because further new reads will be using only the newly created files out of compaction. | 
| double | getCompactionPressure() | 
| Collection<StoreFile> | getFilesForScanOrGet(byte[] startRow,
                    boolean includeStartRow,
                    byte[] stopRow,
                    boolean includeStopRow)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() | 
| Comparator<StoreFile> | getStoreFileComparator() | 
| 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. | 
| void | removeCompactedFiles(Collection<StoreFile> compactedFiles)Remove the compacted files | 
| Iterator<StoreFile> | updateCandidateFilesForRowKeyBefore(Iterator<StoreFile> candidateFiles,
                                   KeyValue targetKey,
                                   Cell candidate)Updates the candidate list for finding row key before. | 
void loadFiles(List<StoreFile> storeFiles)
storeFiles - The files to load.void insertNewFiles(Collection<StoreFile> sfs) throws IOException
sfs - New store files.IOExceptionvoid addCompactionResults(Collection<StoreFile> compactedFiles, Collection<StoreFile> results) throws IOException
compactedFiles - The input files for the compaction.results - The resulting files for the compaction.IOExceptionvoid removeCompactedFiles(Collection<StoreFile> compactedFiles) throws IOException
compactedFiles - the list of compacted filesIOExceptioncom.google.common.collect.ImmutableCollection<StoreFile> clearFiles()
Collection<StoreFile> clearCompactedFiles()
Collection<StoreFile> getStorefiles()
Collection<StoreFile> getCompactedfiles()
int getStorefileCount()
Collection<StoreFile> getFilesForScanOrGet(byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow)
startRow - Start row of the request.stopRow - Stop row of the request.Iterator<StoreFile> getCandidateFilesForRowKeyBefore(KeyValue targetKey)
targetKey - The key that is the basis of the search.Iterator<StoreFile> updateCandidateFilesForRowKeyBefore(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 IOException
IOExceptionint getStoreCompactionPriority()
Collection<StoreFile> getUnneededFiles(long maxTs, List<StoreFile> filesCompacting)
maxTs - Maximum expired timestamp.filesCompacting - Files that are currently compacting.double getCompactionPressure()
Store.getCompactionPressure()Comparator<StoreFile> getStoreFileComparator()
StoreFile.getMaxSequenceId() is the first priority.Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.