@InterfaceAudience.Private public abstract class AbstractMultiOutputCompactor<T extends AbstractMultiFileWriter> extends Compactor<T>
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 |
|---|
AbstractMultiOutputCompactor(org.apache.hadoop.conf.Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
abortWriter(T writer) |
protected void |
initMultiWriter(AbstractMultiFileWriter writer,
InternalScanner scanner,
Compactor.FileDetails fd,
boolean shouldDropBehind) |
commitWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScannerpublic AbstractMultiOutputCompactor(org.apache.hadoop.conf.Configuration conf,
Store store)
protected void initMultiWriter(AbstractMultiFileWriter writer, InternalScanner scanner, Compactor.FileDetails fd, boolean shouldDropBehind)
protected void abortWriter(T writer) throws IOException
abortWriter in class Compactor<T extends AbstractMultiFileWriter>IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.