| Package | Description |
|---|---|
| org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
| org.apache.hadoop.hbase.regionserver | |
| org.apache.hadoop.hbase.regionserver.compactions |
| Modifier and Type | Method and Description |
|---|---|
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.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile,
CompactionRequest request) |
void |
RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
com.google.common.collect.ImmutableList<StoreFile> selected,
CompactionRequest request)
Called after the
StoreFiles to compact have been selected from the available
candidates. |
void |
BaseRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
com.google.common.collect.ImmutableList<StoreFile> selected,
CompactionRequest request) |
InternalScanner |
RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to writing the
StoreFiles selected for compaction into a new
StoreFile. |
InternalScanner |
BaseRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request) |
InternalScanner |
RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s,
CompactionRequest request)
Called prior to writing the
StoreFiles selected for compaction into a new
StoreFile and prior to creating the scanner used to read the input files. |
InternalScanner |
BaseRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s,
CompactionRequest request) |
void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFiles to compact from the list of
available candidates. |
void |
BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<StoreFile> candidates,
CompactionRequest request) |
| Modifier and Type | Method and Description |
|---|---|
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
User user) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
int pri,
CompactionRequest request,
User user) |
private CompactionRequest |
CompactSplitThread.requestCompactionInternal(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
boolean selectNow,
User user) |
| Modifier and Type | Method and Description |
|---|---|
private void |
HStore.finishCompactionRequest(CompactionRequest cr) |
void |
StripeStoreEngine.StripeCompaction.forceSelect(CompactionRequest request) |
private void |
HStore.logCompactionEndMessage(CompactionRequest cr,
List<StoreFile> sfs,
long compactionStartTime)
Log a very elaborate compaction completion message.
|
private List<StoreFile> |
HStore.moveCompatedFilesIntoPlace(CompactionRequest cr,
List<org.apache.hadoop.fs.Path> newFiles,
User user) |
void |
RegionCoprocessorHost.postCompact(Store store,
StoreFile resultFile,
CompactionRequest request)
Called after the store compaction has completed.
|
void |
RegionCoprocessorHost.postCompactSelection(Store store,
com.google.common.collect.ImmutableList<StoreFile> selected,
CompactionRequest request)
Called after the
StoreFiles to be compacted have been selected from the available
candidates. |
InternalScanner |
RegionCoprocessorHost.preCompact(Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to rewriting the store files selected for compaction
|
InternalScanner |
RegionCoprocessorHost.preCompactScannerOpen(Store store,
List<StoreFileScanner> scanners,
ScanType scanType,
long earliestPutTs,
CompactionRequest request)
|
boolean |
RegionCoprocessorHost.preCompactSelection(Store store,
List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFiles for compaction from the list of currently
available candidates. |
CompactionContext |
Store.requestCompaction(int priority,
CompactionRequest baseRequest)
Deprecated.
see requestCompaction(int, CompactionRequest, User)
|
CompactionContext |
HStore.requestCompaction(int priority,
CompactionRequest baseRequest) |
CompactionContext |
Store.requestCompaction(int priority,
CompactionRequest baseRequest,
User user) |
CompactionContext |
HStore.requestCompaction(int priority,
CompactionRequest baseRequest,
User user) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
User user) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
int pri,
CompactionRequest request,
User user) |
private CompactionRequest |
CompactSplitThread.requestCompactionInternal(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
boolean selectNow,
User user) |
private CompactionContext |
CompactSplitThread.selectCompaction(Region r,
Store s,
int priority,
CompactionRequest request,
User user) |
| Modifier and Type | Method and Description |
|---|---|
List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
String why,
int p,
List<Pair<CompactionRequest,Store>> requests,
User user) |
List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
String why,
int pri,
List<Pair<CompactionRequest,Store>> requests,
User user) |
List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
String why,
List<Pair<CompactionRequest,Store>> requests) |
List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
String why,
List<Pair<CompactionRequest,Store>> requests) |
private List<CompactionRequest> |
CompactSplitThread.requestCompactionInternal(Region r,
String why,
int p,
List<Pair<CompactionRequest,Store>> requests,
boolean selectNow,
User user) |
| Modifier and Type | Field and Description |
|---|---|
protected CompactionRequest |
StripeCompactionPolicy.StripeCompactionRequest.request |
protected CompactionRequest |
CompactionContext.request |
| Modifier and Type | Method and Description |
|---|---|
CompactionRequest |
CompactionRequest.combineWith(CompactionRequest other)
Combines the request with other request.
|
CompactionRequest |
StripeCompactionPolicy.StripeCompactionRequest.getRequest() |
CompactionRequest |
CompactionContext.getRequest() |
CompactionRequest |
FIFOCompactionPolicy.selectCompaction(Collection<StoreFile> candidateFiles,
List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
CompactionRequest |
RatioBasedCompactionPolicy.selectCompaction(Collection<StoreFile> candidateFiles,
List<StoreFile> filesCompacting,
boolean isUserCompaction,
boolean mayUseOffPeak,
boolean forceMajor) |
| Modifier and Type | Method and Description |
|---|---|
CompactionRequest |
CompactionRequest.combineWith(CompactionRequest other)
Combines the request with other request.
|
List<org.apache.hadoop.fs.Path> |
DefaultCompactor.compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController) |
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequest request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController) |
List<org.apache.hadoop.fs.Path> |
StripeCompactor.compact(CompactionRequest request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
private List<org.apache.hadoop.fs.Path> |
StripeCompactor.compactInternal(StripeMultiFileWriter mw,
CompactionRequest request,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
int |
CompactionRequest.compareTo(CompactionRequest request)
This function will define where in the priority queue the request will
end up.
|
StripeCompactionPolicy.StripeCompactionRequest |
StripeCompactionPolicy.createEmptyRequest(StripeCompactionPolicy.StripeInformationProvider si,
CompactionRequest request) |
void |
CompactionContext.forceSelect(CompactionRequest request)
Forces external selection to be applied for this compaction.
|
protected InternalScanner |
Compactor.postCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
InternalScanner scanner,
User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
|
protected InternalScanner |
Compactor.preCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
long earliestPutTs,
List<StoreFileScanner> scanners)
Calls coprocessor, if any, to create compaction scanner - before normal scanner creation.
|
protected InternalScanner |
Compactor.preCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
long earliestPutTs,
List<StoreFileScanner> scanners,
User user) |
void |
StripeCompactionPolicy.StripeCompactionRequest.setRequest(CompactionRequest request) |
| Constructor and Description |
|---|
StripeCompactionPolicy.BoundaryStripeCompactionRequest(CompactionRequest request,
List<byte[]> targetBoundaries) |
StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request,
byte[] startRow,
byte[] endRow,
int targetCount,
long targetKvs) |
StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request,
byte[] startRow,
byte[] endRow,
long targetKvs) |
StripeCompactionPolicy.StripeCompactionRequest(CompactionRequest request) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.