@InterfaceAudience.Private public class StripeCompactor extends AbstractMultiOutputCompactor<StripeMultiFileWriter>
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactorycompactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, progress, store| Constructor and Description |
|---|
StripeCompactor(Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.List<Path> |
commitWriter(StripeMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequest request) |
java.util.List<Path> |
compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
compact(CompactionRequest request,
java.util.List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
abortWriter, initMultiWriterappendMetadataAndCloseWriter, compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScannerpublic StripeCompactor(Configuration conf,
Store store)
public java.util.List<Path> compact(CompactionRequest request, java.util.List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController, User user) throws java.io.IOException
java.io.IOExceptionpublic java.util.List<Path> compact(CompactionRequest request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController, User user) throws java.io.IOException
java.io.IOExceptionprotected java.util.List<Path> commitWriter(StripeMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequest request) throws java.io.IOException
commitWriter in class Compactor<StripeMultiFileWriter>java.io.IOException