@InterfaceAudience.Private public interface StoreFileManager
IOException
is the getSplitPoint()
method, where we need to
read startKey, endKey etc, which may lead to an IOException
.
Implementations are assumed to be not thread safe.Modifier and Type | Method and Description |
---|---|
void |
addCompactionResults(Collection<HStoreFile> compactedFiles,
Collection<HStoreFile> results)
Adds only the new compaction results into the structure.
|
Collection<HStoreFile> |
clearCompactedFiles()
Clears all the compacted files and returns them.
|
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> |
clearFiles()
Clears all the files currently in use and returns them.
|
Iterator<HStoreFile> |
getCandidateFilesForRowKeyBefore(KeyValue targetKey)
Gets initial, full list of candidate store files to check for row-key-before.
|
Collection<HStoreFile> |
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.
|
int |
getCompactedFilesCount()
Returns the number of compacted files.
|
double |
getCompactionPressure() |
Collection<HStoreFile> |
getFilesForScan(byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow)
Gets the store files to scan for a Scan or Get request.
|
Optional<byte[]> |
getSplitPoint()
Gets the split point for the split of this set of store files (approx.
|
int |
getStoreCompactionPriority()
Returns The store compaction priority.
|
Comparator<HStoreFile> |
getStoreFileComparator() |
int |
getStorefileCount()
Returns the number of files currently in use.
|
Collection<HStoreFile> |
getStorefiles()
Gets the snapshot of the store files currently in use.
|
Collection<HStoreFile> |
getUnneededFiles(long maxTs,
List<HStoreFile> filesCompacting) |
void |
insertNewFiles(Collection<HStoreFile> sfs)
Adds new files, either for from MemStore flush or bulk insert, into the structure.
|
void |
loadFiles(List<HStoreFile> storeFiles)
Loads the initial store files into empty StoreFileManager.
|
void |
removeCompactedFiles(Collection<HStoreFile> compactedFiles)
Remove the compacted files
|
Iterator<HStoreFile> |
updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
void loadFiles(List<HStoreFile> storeFiles)
storeFiles
- The files to load.void insertNewFiles(Collection<HStoreFile> sfs)
sfs
- New store files.void addCompactionResults(Collection<HStoreFile> compactedFiles, Collection<HStoreFile> results)
compactedFiles
- The input files for the compaction.results
- The resulting files for the compaction.void removeCompactedFiles(Collection<HStoreFile> compactedFiles)
compactedFiles
- the list of compacted filesorg.apache.hbase.thirdparty.com.google.common.collect.ImmutableCollection<HStoreFile> clearFiles()
Collection<HStoreFile> clearCompactedFiles()
Collection<HStoreFile> getStorefiles()
Collection<HStoreFile> getCompactedfiles()
int getStorefileCount()
int getCompactedFilesCount()
Collection<HStoreFile> getFilesForScan(byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow)
startRow
- Start row of the request.stopRow
- Stop row of the request.Iterator<HStoreFile> getCandidateFilesForRowKeyBefore(KeyValue targetKey)
targetKey
- The key that is the basis of the search.Iterator<HStoreFile> updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> 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.Optional<byte[]> getSplitPoint() throws IOException
IOException
int getStoreCompactionPriority()
Collection<HStoreFile> getUnneededFiles(long maxTs, List<HStoreFile> filesCompacting)
maxTs
- Maximum expired timestamp.filesCompacting
- Files that are currently compacting.double getCompactionPressure()
HStore.getCompactionPressure()
Comparator<HStoreFile> getStoreFileComparator()
HStoreFile.getMaxSequenceId()
is the first priority.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.