Modifier and Type | Method and Description |
---|---|
static void |
HFileArchiver.archiveStoreFiles(Configuration conf,
FileSystem fs,
HRegionInfo regionInfo,
Path tableDir,
byte[] family,
java.util.Collection<StoreFile> compactedFiles)
Remove the store files, either by archiving them or outright deletion
|
Modifier and Type | Method and Description |
---|---|
void |
BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile)
Deprecated.
|
void |
SimpleRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
TestCoprocessorInterface.CoprocessorImpl.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
TestRegionObserverInterface.EvenOnlyCompactor.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile,
CompactionRequest request) |
void |
RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
CompactionRequest request)
Called after compaction has completed and the new store file has been moved in to place.
|
void |
BaseRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile)
Called after a Store's memstore is flushed to disk.
|
void |
SimpleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile) |
Modifier and Type | Method and Description |
---|---|
void |
BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates) |
void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates)
Deprecated.
|
void |
SimpleRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates) |
void |
BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request) |
void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFiles to compact from the list of
available candidates. |
Modifier and Type | Method and Description |
---|---|
static void |
MobUtils.removeMobFiles(Configuration conf,
FileSystem fs,
TableName tableName,
Path tableDir,
byte[] family,
java.util.Collection<StoreFile> storeFiles)
Archives the mob files.
|
Constructor and Description |
---|
CachedMobFile(StoreFile sf) |
MobFile(StoreFile sf) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Path> |
PartitionedMobCompactor.compactMobFiles(PartitionedMobCompactionRequest request,
java.util.List<StoreFile> delFiles)
Compacts the selected small mob files and all the del files.
|
void |
TestMobCompactor.CompactTwoLatestHfilesCopro.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
TestNamespaceAuditor.CustomObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
Modifier and Type | Class and Description |
---|---|
class |
MockStoreFile
A mock used so our tests don't deal with actual StoreFiles
|
Modifier and Type | Field and Description |
---|---|
static java.util.Comparator<StoreFile> |
StoreFile.Comparators.SEQ_ID
Comparator that compares based on the Sequence Ids of the
the StoreFiles.
|
static java.util.Comparator<StoreFile> |
StoreFile.Comparators.SEQ_ID_MAX_TIMESTAMP
Comparator for time-aware compaction.
|
Modifier and Type | Method and Description |
---|---|
StoreFile |
StoreFile.cloneForReader()
Clone a StoreFile for opening private reader.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<byte[],java.util.List<StoreFile>> |
HRegion.close()
Close down this HRegion.
|
java.util.Collection<StoreFile> |
Store.close()
Close all the readers We don't need to worry about subsequent requests because the Region
holds a write lock that will prevent any more reads or writes.
|
java.util.Map<byte[],java.util.List<StoreFile>> |
HRegion.close(boolean abort)
Close down this HRegion.
|
java.util.List<StoreFile> |
HStore.compact(CompactionContext compaction,
CompactionThroughputController throughputController)
Compact the StoreFiles.
|
java.util.List<StoreFile> |
Store.compact(CompactionContext compaction,
CompactionThroughputController throughputController)
Deprecated.
see compact(CompactionContext, CompactionThroughputController, User)
|
java.util.List<StoreFile> |
HStore.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
java.util.List<StoreFile> |
Store.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
java.util.Iterator<StoreFile> |
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue targetKey)
Gets initial, full list of candidate store files to check for row-key-before.
|
java.util.Iterator<StoreFile> |
StripeStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue targetKey)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue)
for details on this methods. |
java.util.Collection<StoreFile> |
StoreFileManager.getFilesForScanOrGet(boolean isGet,
byte[] startRow,
byte[] stopRow)
Gets the store files to scan for a Scan or Get request.
|
java.util.Collection<StoreFile> |
StripeStoreFileManager.getFilesForScanOrGet(boolean isGet,
byte[] startRow,
byte[] stopRow) |
java.util.List<StoreFile> |
StripeStoreFileManager.getLevel0Files() |
java.util.Comparator<StoreFile> |
StoreFileManager.getStoreFileComparator() |
java.util.Comparator<StoreFile> |
StripeStoreFileManager.getStoreFileComparator() |
java.util.Collection<StoreFile> |
HStore.getStorefiles() |
java.util.Collection<StoreFile> |
Store.getStorefiles() |
java.util.Collection<StoreFile> |
StoreFileManager.getStorefiles()
Gets the snapshot of the store files currently in use.
|
java.util.Collection<StoreFile> |
StripeStoreFileManager.getStorefiles() |
java.util.Collection<StoreFile> |
StoreFileManager.getUnneededFiles(long maxTs,
java.util.List<StoreFile> filesCompacting) |
java.util.Collection<StoreFile> |
StripeStoreFileManager.getUnneededFiles(long maxTs,
java.util.List<StoreFile> filesCompacting) |
java.util.List<StoreFile> |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.preSelect(java.util.List<StoreFile> filesCompacting) |
java.util.Iterator<StoreFile> |
StoreFileManager.updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
java.util.Iterator<StoreFile> |
StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue) and
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods. |
Modifier and Type | Method and Description |
---|---|
void |
RegionCoprocessorHost.postCompact(Store store,
StoreFile resultFile,
CompactionRequest request)
Called after the store compaction has completed.
|
void |
RegionCoprocessorHost.postFlush(Store store,
StoreFile storeFile)
Invoked after a memstore flush
|
Modifier and Type | Method and Description |
---|---|
void |
StoreFileManager.addCompactionResults(java.util.Collection<StoreFile> compactedFiles,
java.util.Collection<StoreFile> results)
Adds compaction results into the structure.
|
void |
StoreFileManager.addCompactionResults(java.util.Collection<StoreFile> compactedFiles,
java.util.Collection<StoreFile> results)
Adds compaction results into the structure.
|
void |
StripeStoreFileManager.addCompactionResults(java.util.Collection<StoreFile> compactedFiles,
java.util.Collection<StoreFile> results) |
void |
StripeStoreFileManager.addCompactionResults(java.util.Collection<StoreFile> compactedFiles,
java.util.Collection<StoreFile> results) |
protected void |
HStore.completeCompaction(java.util.Collection<StoreFile> compactedFiles)
It works by processing a compaction that's been written to disk.
|
protected void |
HStore.completeCompaction(java.util.Collection<StoreFile> compactedFiles,
boolean removeFiles)
It works by processing a compaction that's been written to disk.
|
static java.lang.Integer |
StoreUtils.getDeterministicRandomSeed(java.util.Collection<StoreFile> files)
Creates a deterministic hash code for store file collection.
|
static long |
StoreUtils.getLowestTimestamp(java.util.Collection<StoreFile> candidates)
Gets lowest timestamp from candidate StoreFiles
|
static long |
StoreFile.getMaxMemstoreTSInList(java.util.Collection<StoreFile> sfs)
Return the largest memstoreTS found across all storefiles in
the given list.
|
static long |
StoreFile.getMaxSequenceIdInList(java.util.Collection<StoreFile> sfs)
Return the highest sequence ID found across all storefiles in
the given list.
|
static java.util.List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(java.util.Collection<StoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
long readPt)
Return an array of scanners corresponding to the given set of store files.
|
static java.util.List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(java.util.Collection<StoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
ScanQueryMatcher matcher,
long readPt) |
static java.util.List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(java.util.Collection<StoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
ScanQueryMatcher matcher,
long readPt,
boolean isPrimaryReplica)
Return an array of scanners corresponding to the given set of store files,
And set the ScanQueryMatcher for each store file scanner for further
optimization
|
static java.util.List<StoreFileScanner> |
StoreFileScanner.getScannersForStoreFiles(java.util.Collection<StoreFile> files,
boolean cacheBlocks,
boolean usePread,
long readPt)
Return an array of scanners corresponding to the given
set of store files.
|
java.util.Collection<StoreFile> |
StoreFileManager.getUnneededFiles(long maxTs,
java.util.List<StoreFile> filesCompacting) |
java.util.Collection<StoreFile> |
StripeStoreFileManager.getUnneededFiles(long maxTs,
java.util.List<StoreFile> filesCompacting) |
static boolean |
StoreUtils.hasReferences(java.util.Collection<StoreFile> files)
Determines whether any files in the collection are references.
|
void |
StoreFileManager.insertNewFiles(java.util.Collection<StoreFile> sfs)
Adds new files, either for from MemStore flush or bulk insert, into the structure.
|
void |
StripeStoreFileManager.insertNewFiles(java.util.Collection<StoreFile> sfs) |
void |
StoreFileManager.loadFiles(java.util.List<StoreFile> storeFiles)
Loads the initial store files into empty StoreFileManager.
|
void |
StripeStoreFileManager.loadFiles(java.util.List<StoreFile> storeFiles) |
boolean |
DateTieredStoreEngine.needsCompaction(java.util.List<StoreFile> filesCompacting) |
boolean |
DefaultStoreEngine.needsCompaction(java.util.List<StoreFile> filesCompacting) |
abstract boolean |
StoreEngine.needsCompaction(java.util.List<StoreFile> filesCompacting) |
boolean |
StripeStoreEngine.needsCompaction(java.util.List<StoreFile> filesCompacting) |
boolean |
RegionCoprocessorHost.preCompactSelection(Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFile s for compaction from the list of currently
available candidates. |
java.util.List<StoreFile> |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.preSelect(java.util.List<StoreFile> filesCompacting) |
void |
HRegionFileSystem.removeStoreFiles(java.lang.String familyName,
java.util.Collection<StoreFile> storeFiles)
Closes and archives the specified store files from the specified family.
|
boolean |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.select(java.util.List<StoreFile> f,
boolean i,
boolean m,
boolean e) |
java.util.Iterator<StoreFile> |
StoreFileManager.updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
Updates the candidate list for finding row key before.
|
java.util.Iterator<StoreFile> |
StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(java.util.Iterator<StoreFile> candidateFiles,
KeyValue targetKey,
Cell candidate)
See
StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue) and
StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)
for details on this methods. |
Constructor and Description |
---|
StoreFile(StoreFile other)
Clone
|
Modifier and Type | Method and Description |
---|---|
static StoreFile |
TestCompactor.createDummyStoreFile(long maxSequenceId) |
Modifier and Type | Method and Description |
---|---|
protected java.util.ArrayList<StoreFile> |
ExploringCompactionPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mightBeStuck) |
protected java.util.ArrayList<StoreFile> |
RatioBasedCompactionPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mayBeStuck)
-- Default minor compaction selection algorithm:
choose CompactSelection from candidates --
First exclude bulk-load files if indicated in configuration.
|
protected java.util.ArrayList<StoreFile> |
EverythingPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mayBeStuck) |
java.util.List<StoreFile> |
ExploringCompactionPolicy.applyCompactionPolicy(java.util.List<StoreFile> candidates,
boolean mightBeStuck,
boolean mayUseOffPeak,
int minFiles,
int maxFiles) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.checkMinFilesCriteria(java.util.ArrayList<StoreFile> candidates,
int minFiles) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.filterBulk(java.util.ArrayList<StoreFile> candidates) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.getCurrentEligibleFiles(java.util.ArrayList<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting) |
java.util.Collection<StoreFile> |
CompactionRequest.getFiles() |
java.util.List<StoreFile> |
StripeCompactionPolicy.StripeInformationProvider.getLevel0Files() |
java.util.Collection<StoreFile> |
StripeCompactionPolicy.StripeInformationProvider.getStorefiles() |
abstract java.util.List<StoreFile> |
CompactionContext.preSelect(java.util.List<StoreFile> filesCompacting)
Called before coprocessor preCompactSelection and should filter the candidates
for coprocessor; i.e.
|
java.util.List<StoreFile> |
SortedCompactionPolicy.preSelectCompactionForCoprocessor(java.util.Collection<StoreFile> candidates,
java.util.List<StoreFile> filesCompacting) |
java.util.List<StoreFile> |
StripeCompactionPolicy.preSelectFilesForCoprocessor(StripeCompactionPolicy.StripeInformationProvider si,
java.util.List<StoreFile> filesCompacting) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.skipLargeFiles(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffpeak) |
Modifier and Type | Method and Description |
---|---|
protected java.util.ArrayList<StoreFile> |
ExploringCompactionPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mightBeStuck) |
protected java.util.ArrayList<StoreFile> |
RatioBasedCompactionPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mayBeStuck)
-- Default minor compaction selection algorithm:
choose CompactSelection from candidates --
First exclude bulk-load files if indicated in configuration.
|
protected java.util.ArrayList<StoreFile> |
EverythingPolicy.applyCompactionPolicy(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffPeak,
boolean mayBeStuck) |
java.util.List<StoreFile> |
ExploringCompactionPolicy.applyCompactionPolicy(java.util.List<StoreFile> candidates,
boolean mightBeStuck,
boolean mayUseOffPeak,
int minFiles,
int maxFiles) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.checkMinFilesCriteria(java.util.ArrayList<StoreFile> candidates,
int minFiles) |
java.util.List<Path> |
DefaultCompactor.compactForTesting(java.util.Collection<StoreFile> filesToCompact,
boolean isMajor)
Compact a list of files for testing.
|
protected CompactionRequest |
DateTieredCompactionPolicy.createCompactionRequest(java.util.ArrayList<StoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected CompactionRequest |
RatioBasedCompactionPolicy.createCompactionRequest(java.util.ArrayList<StoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected abstract CompactionRequest |
SortedCompactionPolicy.createCompactionRequest(java.util.ArrayList<StoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected java.util.List<StoreFileScanner> |
Compactor.createFileScanners(java.util.Collection<StoreFile> filesToCompact,
long smallestReadPoint)
Creates file scanners for compaction.
|
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.filterBulk(java.util.ArrayList<StoreFile> candidates) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.getCurrentEligibleFiles(java.util.ArrayList<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.getCurrentEligibleFiles(java.util.ArrayList<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting) |
protected Compactor.FileDetails |
Compactor.getFileDetails(java.util.Collection<StoreFile> filesToCompact,
boolean allFiles)
Extracts some details about the files to compact that are commonly needed by compactors.
|
long |
SortedCompactionPolicy.getNextMajorCompactTime(java.util.Collection<StoreFile> filesToCompact) |
static long |
StripeCompactionPolicy.getTotalFileSize(java.util.Collection<StoreFile> candidates) |
boolean |
DateTieredCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting)
Heuristics for guessing whether we need minor compaction.
|
boolean |
DateTieredCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting)
Heuristics for guessing whether we need minor compaction.
|
boolean |
FIFOCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting) |
boolean |
FIFOCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting) |
boolean |
RatioBasedCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting)
A heuristic method to decide whether to schedule a compaction request
|
boolean |
RatioBasedCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting)
A heuristic method to decide whether to schedule a compaction request
|
abstract boolean |
SortedCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting) |
abstract boolean |
SortedCompactionPolicy.needsCompaction(java.util.Collection<StoreFile> storeFiles,
java.util.List<StoreFile> filesCompacting) |
boolean |
StripeCompactionPolicy.needsCompactions(StripeCompactionPolicy.StripeInformationProvider si,
java.util.List<StoreFile> filesCompacting) |
abstract java.util.List<StoreFile> |
CompactionContext.preSelect(java.util.List<StoreFile> filesCompacting)
Called before coprocessor preCompactSelection and should filter the candidates
for coprocessor; i.e.
|
java.util.List<StoreFile> |
SortedCompactionPolicy.preSelectCompactionForCoprocessor(java.util.Collection<StoreFile> candidates,
java.util.List<StoreFile> filesCompacting) |
java.util.List<StoreFile> |
SortedCompactionPolicy.preSelectCompactionForCoprocessor(java.util.Collection<StoreFile> candidates,
java.util.List<StoreFile> filesCompacting) |
java.util.List<StoreFile> |
StripeCompactionPolicy.preSelectFilesForCoprocessor(StripeCompactionPolicy.StripeInformationProvider si,
java.util.List<StoreFile> filesCompacting) |
protected void |
SortedCompactionPolicy.removeExcessFiles(java.util.ArrayList<StoreFile> candidates,
boolean isUserCompaction,
boolean isMajorCompaction) |
abstract boolean |
CompactionContext.select(java.util.List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor)
Called to select files for compaction.
|
CompactionRequest |
FIFOCompactionPolicy.selectCompaction(java.util.Collection<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequest |
FIFOCompactionPolicy.selectCompaction(java.util.Collection<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequest |
SortedCompactionPolicy.selectCompaction(java.util.Collection<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequest |
SortedCompactionPolicy.selectCompaction(java.util.Collection<StoreFile> candidateFiles,
java.util.List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
StripeCompactionPolicy.StripeCompactionRequest |
StripeCompactionPolicy.selectCompaction(StripeCompactionPolicy.StripeInformationProvider si,
java.util.List<StoreFile> filesCompacting,
boolean isOffpeak) |
CompactionRequest |
DateTieredCompactionPolicy.selectMajorCompaction(java.util.ArrayList<StoreFile> candidateSelection) |
CompactionRequest |
DateTieredCompactionPolicy.selectMinorCompaction(java.util.ArrayList<StoreFile> candidateSelection,
boolean mayUseOffPeak,
boolean mayBeStuck)
We receive store files sorted in ascending order by seqId then scan the list of files.
|
abstract boolean |
CompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
boolean |
DateTieredCompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
boolean |
FIFOCompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
boolean |
RatioBasedCompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
abstract boolean |
SortedCompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
boolean |
StripeCompactionPolicy.shouldPerformMajorCompaction(java.util.Collection<StoreFile> filesToCompact) |
protected java.util.ArrayList<StoreFile> |
SortedCompactionPolicy.skipLargeFiles(java.util.ArrayList<StoreFile> candidates,
boolean mayUseOffpeak) |
void |
CompactionRequest.updateFiles(java.util.Collection<StoreFile> files) |
Constructor and Description |
---|
CompactionRequest(java.util.Collection<StoreFile> files) |
DateTieredCompactionRequest(java.util.Collection<StoreFile> files,
java.util.List<java.lang.Long> boundaryList) |