@InterfaceAudience.Private public class DateTieredCompactor extends AbstractMultiOutputCompactor<DateTieredMultiFileWriter>
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactorycompactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, progress, store| Constructor and Description |
|---|
DateTieredCompactor(Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
protected List<Path> |
commitWriter(DateTieredMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequest request) |
List<Path> |
compact(CompactionRequest request,
List<Long> lowerBoundaries,
CompactionThroughputController throughputController,
User user) |
abortWriter, initMultiWriterappendMetadataAndCloseWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScannerpublic DateTieredCompactor(Configuration conf,
Store store)
public List<Path> compact(CompactionRequest request, List<Long> lowerBoundaries, CompactionThroughputController throughputController, User user) throws IOException
IOExceptionprotected List<Path> commitWriter(DateTieredMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequest request) throws IOException
commitWriter in class Compactor<DateTieredMultiFileWriter>IOException