@InterfaceAudience.Private public class DefaultMobStoreCompactor extends DefaultCompactor
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, progress, store
Constructor and Description |
---|
DefaultMobStoreCompactor(Configuration conf,
Store store) |
Modifier and Type | Method and Description |
---|---|
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.
|
protected boolean |
performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
Compactor.CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
CompactionThroughputController throughputController,
boolean major)
Performs compaction on a column family with the mob flag enabled.
|
abortWriter, commitWriter, compactForTesting, createTmpWriter
appendMetadataAndCloseWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScanner
public DefaultMobStoreCompactor(Configuration conf, Store store)
public java.util.List<Path> compact(CompactionRequest request, CompactionThroughputController throughputController, User user) throws java.io.IOException
DefaultCompactor
compact
in class DefaultCompactor
java.io.IOException
protected boolean performCompaction(Compactor.FileDetails fd, InternalScanner scanner, Compactor.CellSink writer, long smallestReadPoint, boolean cleanSeqId, CompactionThroughputController throughputController, boolean major) throws java.io.IOException
performCompaction
in class Compactor<StoreFile.Writer>
fd
- File detailsscanner
- Where to read from.writer
- Where to write to.smallestReadPoint
- Smallest read point.cleanSeqId
- When true, remove seqId(used to be mvcc) value which is <= smallestReadPointthroughputController
- The compaction throughput controller.major
- Is a major compaction.java.io.IOException