private class DefaultStoreEngine.DefaultCompactionContext extends CompactionContext
request| Modifier | Constructor and Description |
|---|---|
private |
DefaultStoreEngine.DefaultCompactionContext() |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.hadoop.fs.Path> |
compact(CompactionThroughputController throughputController)
Runs the compaction based on current selection.
|
List<org.apache.hadoop.fs.Path> |
compact(CompactionThroughputController throughputController,
User user) |
List<StoreFile> |
preSelect(List<StoreFile> filesCompacting)
Called before coprocessor preCompactSelection and should filter the candidates
for coprocessor; i.e.
|
boolean |
select(List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor)
Called to select files for compaction.
|
forceSelect, getRequest, hasSelectionprivate DefaultStoreEngine.DefaultCompactionContext()
public boolean select(List<StoreFile> filesCompacting, boolean isUserCompaction, boolean mayUseOffPeak, boolean forceMajor) throws IOException
CompactionContextselect in class CompactionContextfilesCompacting - Files currently being compacted by other compactions.isUserCompaction - Whether this is a user compaction.mayUseOffPeak - Whether the underlying policy may assume it's off-peak hours.forceMajor - Whether to force major compaction.IOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionThroughputController throughputController) throws IOException
CompactionContextcompact in class CompactionContextIOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionThroughputController throughputController, User user) throws IOException
compact in class CompactionContextIOExceptionpublic List<StoreFile> preSelect(List<StoreFile> filesCompacting)
CompactionContextpreSelect in class CompactionContextfilesCompacting - files currently compactingCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.