@InterfaceAudience.Private public class DefaultCompactor extends Compactor<StoreFile.Writer>
compact(CompactionRequest, ThroughputController, User)Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactorycompactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, MINOR_COMPACTION_DROP_CACHE, progress, store| Constructor and Description |
|---|
DefaultCompactor(org.apache.hadoop.conf.Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
abortWriter(StoreFile.Writer writer) |
protected List<org.apache.hadoop.fs.Path> |
commitWriter(StoreFile.Writer writer,
Compactor.FileDetails fd,
CompactionRequest request) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
ThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
List<org.apache.hadoop.fs.Path> |
compactForTesting(Collection<StoreFile> filesToCompact,
boolean isMajor)
Compact a list of files for testing.
|
compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScannerpublic DefaultCompactor(org.apache.hadoop.conf.Configuration conf,
Store store)
public List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, ThroughputController throughputController, User user) throws IOException
IOExceptionpublic List<org.apache.hadoop.fs.Path> compactForTesting(Collection<StoreFile> filesToCompact, boolean isMajor) throws IOException
CompactionRequest to pass to
compact(CompactionRequest, ThroughputController, 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)IOExceptionprotected List<org.apache.hadoop.fs.Path> commitWriter(StoreFile.Writer writer, Compactor.FileDetails fd, CompactionRequest request) throws IOException
commitWriter in class Compactor<StoreFile.Writer>IOExceptionprotected void abortWriter(StoreFile.Writer writer) throws IOException
abortWriter in class Compactor<StoreFile.Writer>IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.