public class DefaultCompactor extends Compactor<StoreFileWriter>
compact(CompactionRequestImpl, ThroughputController, User)
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 |
---|
DefaultCompactor(Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
protected void |
abortWriter(StoreFileWriter writer) |
protected java.util.List<Path> |
commitWriter(StoreFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
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.
|
java.util.List<Path> |
compactForTesting(java.util.Collection<HStoreFile> filesToCompact,
boolean isMajor)
Compact a list of files for testing.
|
compact, createScanner, createScanner, createTmpWriter, getProgress, performCompaction
public DefaultCompactor(Configuration conf, HStore store)
public java.util.List<Path> compact(CompactionRequestImpl request, ThroughputController throughputController, User user) throws java.io.IOException
java.io.IOException
public java.util.List<Path> compactForTesting(java.util.Collection<HStoreFile> filesToCompact, boolean isMajor) throws java.io.IOException
CompactionRequestImpl
to pass to
compact(CompactionRequestImpl, ThroughputController, User)
;filesToCompact
- the files to compact. These are used as the compactionSelection for the
generated CompactionRequestImpl
.isMajor
- true to major compact (prune all deletes, max versions, etc)java.io.IOException
protected java.util.List<Path> commitWriter(StoreFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) throws java.io.IOException
commitWriter
in class Compactor<StoreFileWriter>
java.io.IOException
protected void abortWriter(StoreFileWriter writer) throws java.io.IOException
abortWriter
in class Compactor<StoreFileWriter>
java.io.IOException