public class DefaultMobStoreCompactor extends DefaultCompactor
Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
COMPACTION_PROGRESS_LOG_INTERVAL, compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, MINOR_COMPACTION_DROP_CACHE, progress, store
Constructor and Description |
---|
DefaultMobStoreCompactor(Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
compact(CompactionRequestImpl request,
ThroughputController 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,
CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
ThroughputController throughputController,
boolean major,
int numofFilesToCompact)
Performs compaction on a column family with the mob flag enabled.
|
abortWriter, commitWriter, compactForTesting
compact, createScanner, createScanner, createTmpWriter, getProgress
public DefaultMobStoreCompactor(Configuration conf, HStore store)
public java.util.List<Path> compact(CompactionRequestImpl request, ThroughputController throughputController, User user) throws java.io.IOException
DefaultCompactor
compact
in class DefaultCompactor
java.io.IOException
protected boolean performCompaction(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, boolean major, int numofFilesToCompact) throws java.io.IOException
performCompaction
in class Compactor<StoreFileWriter>
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.numofFilesToCompact
- the number of files to compactjava.io.IOException