@InterfaceAudience.Private public abstract class AbstractMultiOutputCompactor<T extends AbstractMultiFileWriter> extends Compactor<T>
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, progress, store
Constructor and Description |
---|
AbstractMultiOutputCompactor(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) |
appendMetadataAndCloseWriter, commitWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScanner
public AbstractMultiOutputCompactor(Configuration conf, Store store)
protected void initMultiWriter(AbstractMultiFileWriter writer, InternalScanner scanner, Compactor.FileDetails fd, boolean shouldDropBehind)
protected void abortWriter(T writer) throws java.io.IOException
abortWriter
in class Compactor<T extends AbstractMultiFileWriter>
java.io.IOException