private class StripeStoreEngine.StripeCompaction extends CompactionContext
Modifier and Type | Field and Description |
---|---|
private StripeCompactionPolicy.StripeCompactionRequest |
stripeRequest |
request
Modifier | Constructor and Description |
---|---|
private |
StripeCompaction() |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.fs.Path> |
compact(ThroughputController throughputController,
User user) |
void |
forceSelect(CompactionRequestImpl request)
Forces external selection to be applied for this compaction.
|
List<HStoreFile> |
preSelect(List<HStoreFile> filesCompacting)
Called before coprocessor preCompactSelection and should filter the candidates for coprocessor;
i.e.
|
boolean |
select(List<HStoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor)
Called to select files for compaction.
|
getRequest, hasSelection
private StripeCompactionPolicy.StripeCompactionRequest stripeRequest
private StripeCompaction()
public List<HStoreFile> preSelect(List<HStoreFile> filesCompacting)
CompactionContext
preSelect
in class CompactionContext
filesCompacting
- files currently compactingpublic boolean select(List<HStoreFile> filesCompacting, boolean isUserCompaction, boolean mayUseOffPeak, boolean forceMajor) throws IOException
CompactionContext
select
in class CompactionContext
filesCompacting
- 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.IOException
public void forceSelect(CompactionRequestImpl request)
CompactionContext
forceSelect
in class CompactionContext
request
- The pre-cooked request with selection and other settings.public List<org.apache.hadoop.fs.Path> compact(ThroughputController throughputController, User user) throws IOException
compact
in class CompactionContext
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.