Package | Description |
---|---|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
DefaultMobStoreCompactor.compact(CompactionRequestImpl request,
ThroughputController throughputController,
User user) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<HStoreFile> |
HStore.doCompaction(CompactionRequestImpl cr,
java.util.Collection<HStoreFile> filesToCompact,
User user,
long compactionStartTime,
java.util.List<Path> newFiles) |
Modifier and Type | Class and Description |
---|---|
class |
DateTieredCompactionRequest |
Modifier and Type | Field and Description |
---|---|
protected CompactionRequestImpl |
StripeCompactionPolicy.StripeCompactionRequest.request |
protected CompactionRequestImpl |
CompactionContext.request |
Modifier and Type | Method and Description |
---|---|
protected CompactionRequestImpl |
DateTieredCompactionPolicy.createCompactionRequest(java.util.ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected CompactionRequestImpl |
RatioBasedCompactionPolicy.createCompactionRequest(java.util.ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected abstract CompactionRequestImpl |
SortedCompactionPolicy.createCompactionRequest(java.util.ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
CompactionRequestImpl |
StripeCompactionPolicy.StripeCompactionRequest.getRequest() |
CompactionRequestImpl |
CompactionContext.getRequest() |
CompactionRequestImpl |
SortedCompactionPolicy.selectCompaction(java.util.Collection<HStoreFile> candidateFiles,
java.util.List<HStoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequestImpl |
FIFOCompactionPolicy.selectCompaction(java.util.Collection<HStoreFile> candidateFiles,
java.util.List<HStoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequestImpl |
DateTieredCompactionPolicy.selectMajorCompaction(java.util.ArrayList<HStoreFile> candidateSelection) |
CompactionRequestImpl |
DateTieredCompactionPolicy.selectMinorCompaction(java.util.ArrayList<HStoreFile> candidateSelection,
boolean mayUseOffPeak,
boolean mayBeStuck)
We receive store files sorted in ascending order by seqId then scan the list of files.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Path> |
DateTieredCompactor.commitWriter(DateTieredMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected java.util.List<Path> |
DefaultCompactor.commitWriter(StoreFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected java.util.List<Path> |
StripeCompactor.commitWriter(StripeMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected abstract java.util.List<Path> |
Compactor.commitWriter(T writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected java.util.List<Path> |
Compactor.compact(CompactionRequestImpl request,
Compactor.InternalScannerFactory scannerFactory,
Compactor.CellSinkFactory<T> sinkFactory,
ThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequestImpl request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequestImpl request,
java.util.List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
java.util.List<Path> |
DateTieredCompactor.compact(CompactionRequestImpl request,
java.util.List<java.lang.Long> lowerBoundaries,
ThroughputController throughputController,
User user) |
java.util.List<Path> |
DefaultCompactor.compact(CompactionRequestImpl request,
ThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
StripeCompactionPolicy.StripeCompactionRequest |
StripeCompactionPolicy.createEmptyRequest(StripeCompactionPolicy.StripeInformationProvider si,
CompactionRequestImpl request) |
void |
CompactionContext.forceSelect(CompactionRequestImpl request)
Forces external selection to be applied for this compaction.
|
ScanType |
Compactor.InternalScannerFactory.getScanType(CompactionRequestImpl request) |
void |
StripeCompactionPolicy.StripeCompactionRequest.setRequest(CompactionRequestImpl request) |
Constructor and Description |
---|
StripeCompactionRequest(CompactionRequestImpl request) |