@InterfaceAudience.Private public class DefaultCompactor extends Compactor<StoreFile.Writer>
compact(CompactionRequest, CompactionThroughputController, User)
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, progress, store
Constructor and Description |
---|
DefaultCompactor(Configuration conf,
Store store) |
Modifier and Type | Method and Description |
---|---|
protected void |
abortWriter(StoreFile.Writer writer) |
protected java.util.List<Path> |
commitWriter(StoreFile.Writer writer,
Compactor.FileDetails fd,
CompactionRequest request) |
java.util.List<Path> |
compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
java.util.List<Path> |
compactForTesting(java.util.Collection<StoreFile> filesToCompact,
boolean isMajor)
Compact a list of files for testing.
|
protected StoreFile.Writer |
createTmpWriter(Compactor.FileDetails fd,
long smallestReadPoint)
Creates a writer for a new file in a temporary directory.
|
appendMetadataAndCloseWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScanner
public DefaultCompactor(Configuration conf, Store store)
public java.util.List<Path> compact(CompactionRequest request, CompactionThroughputController throughputController, User user) throws java.io.IOException
java.io.IOException
protected StoreFile.Writer createTmpWriter(Compactor.FileDetails fd, long smallestReadPoint) throws java.io.IOException
fd
- The file details.smallestReadPoint
- The smallest mvcc readPoint across all the scanners in this region.java.io.IOException
public java.util.List<Path> compactForTesting(java.util.Collection<StoreFile> filesToCompact, boolean isMajor) throws java.io.IOException
CompactionRequest
to pass to
compact(CompactionRequest, CompactionThroughputController, User)
;filesToCompact
- the files to compact. These are used as the compactionSelection for
the generated CompactionRequest
.isMajor
- true to major compact (prune all deletes, max versions, etc)java.io.IOException
protected java.util.List<Path> commitWriter(StoreFile.Writer writer, Compactor.FileDetails fd, CompactionRequest request) throws java.io.IOException
commitWriter
in class Compactor<StoreFile.Writer>
java.io.IOException
protected void abortWriter(StoreFile.Writer writer) throws java.io.IOException
abortWriter
in class Compactor<StoreFile.Writer>
java.io.IOException