Package | Description |
---|---|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.fs.Path> |
DefaultMobStoreCompactor.compact(CompactionRequestImpl request,
ThroughputController throughputController,
User user) |
Modifier and Type | Method and Description |
---|---|
protected List<HStoreFile> |
HStore.doCompaction(CompactionRequestImpl cr,
Collection<HStoreFile> filesToCompact,
User user,
long compactionStartTime,
List<org.apache.hadoop.fs.Path> newFiles) |
private void |
HStore.finishCompactionRequest(CompactionRequestImpl cr) |
void |
StripeStoreEngine.StripeCompaction.forceSelect(CompactionRequestImpl request) |
void |
DateTieredStoreEngine.DateTieredCompactionContext.forceSelect(CompactionRequestImpl request) |
private void |
HStore.logCompactionEndMessage(CompactionRequestImpl cr,
List<HStoreFile> sfs,
long now,
long compactionStartTime)
Log a very elaborate compaction completion message.
|
private List<HStoreFile> |
HStore.moveCompactedFilesIntoPlace(CompactionRequestImpl cr,
List<org.apache.hadoop.fs.Path> newFiles,
User user) |
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(ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected CompactionRequestImpl |
RatioBasedCompactionPolicy.createCompactionRequest(ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
protected abstract CompactionRequestImpl |
SortedCompactionPolicy.createCompactionRequest(ArrayList<HStoreFile> candidateSelection,
boolean tryingMajor,
boolean mayUseOffPeak,
boolean mayBeStuck) |
CompactionRequestImpl |
StripeCompactionPolicy.StripeCompactionRequest.getRequest() |
CompactionRequestImpl |
CompactionContext.getRequest() |
CompactionRequestImpl |
SortedCompactionPolicy.selectCompaction(Collection<HStoreFile> candidateFiles,
List<HStoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequestImpl |
FIFOCompactionPolicy.selectCompaction(Collection<HStoreFile> candidateFiles,
List<HStoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequestImpl |
DateTieredCompactionPolicy.selectMajorCompaction(ArrayList<HStoreFile> candidateSelection) |
CompactionRequestImpl |
DateTieredCompactionPolicy.selectMinorCompaction(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 List<org.apache.hadoop.fs.Path> |
DateTieredCompactor.commitWriter(DateTieredMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected List<org.apache.hadoop.fs.Path> |
DefaultCompactor.commitWriter(StoreFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected List<org.apache.hadoop.fs.Path> |
StripeCompactor.commitWriter(StripeMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected abstract List<org.apache.hadoop.fs.Path> |
Compactor.commitWriter(T writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
protected List<org.apache.hadoop.fs.Path> |
Compactor.compact(CompactionRequestImpl request,
Compactor.InternalScannerFactory scannerFactory,
Compactor.CellSinkFactory<T> sinkFactory,
ThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequestImpl request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequestImpl request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
DateTieredCompactor.compact(CompactionRequestImpl request,
List<Long> lowerBoundaries,
ThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.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 |
StripeCompactor.StripeInternalScannerFactory.getScanType(CompactionRequestImpl request) |
ScanType |
Compactor.InternalScannerFactory.getScanType(CompactionRequestImpl request) |
private boolean |
DateTieredCompactor.needEmptyFile(CompactionRequestImpl request) |
private InternalScanner |
Compactor.postCompactScannerOpen(CompactionRequestImpl request,
ScanType scanType,
InternalScanner scanner,
User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
|
private ScanInfo |
Compactor.preCompactScannerOpen(CompactionRequestImpl request,
ScanType scanType,
User user) |
void |
StripeCompactionPolicy.StripeCompactionRequest.setRequest(CompactionRequestImpl request) |
Constructor and Description |
---|
BoundaryStripeCompactionRequest(CompactionRequestImpl request,
List<byte[]> targetBoundaries) |
SplitStripeCompactionRequest(CompactionRequestImpl request,
byte[] startRow,
byte[] endRow,
int targetCount,
long targetKvs) |
StripeCompactionRequest(CompactionRequestImpl request) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.