Package | Description |
---|---|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
protected boolean |
DefaultMobStoreCompactor.performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController,
boolean major,
int numofFilesToCompact)
Performs compaction on a column family with the mob flag enabled.
|
Modifier and Type | Method and Description |
---|---|
private Compactor.FileDetails |
Compactor.getFileDetails(Collection<HStoreFile> filesToCompact,
boolean allFiles)
Extracts some details about the files to compact that are commonly needed by compactors.
|
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) |
InternalScanner |
Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo,
List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
InternalScanner |
StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo,
List<StoreFileScanner> scanners,
ScanType scanType,
Compactor.FileDetails fd,
long smallestReadPoint) |
protected StoreFileWriter |
Compactor.createTmpWriter(Compactor.FileDetails fd,
boolean shouldDropBehind)
Creates a writer for a new file in a temporary directory.
|
S |
Compactor.CellSinkFactory.createWriter(InternalScanner scanner,
Compactor.FileDetails fd,
boolean shouldDropBehind) |
protected void |
AbstractMultiOutputCompactor.initMultiWriter(AbstractMultiFileWriter writer,
InternalScanner scanner,
Compactor.FileDetails fd,
boolean shouldDropBehind) |
protected boolean |
Compactor.performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController,
boolean major,
int numofFilesToCompact)
Performs the compaction.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.