public class StripeCompactor extends AbstractMultiOutputCompactor<StripeMultiFileWriter>
Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
COMPACTION_PROGRESS_LOG_INTERVAL, compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, MINOR_COMPACTION_DROP_CACHE, progress, store
Constructor and Description |
---|
StripeCompactor(Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Path> |
commitWriter(StripeMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
java.util.List<Path> |
compact(CompactionRequestImpl request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
java.util.List<Path> |
compact(CompactionRequestImpl request,
java.util.List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
abortWriter, initMultiWriter
compact, createScanner, createScanner, createTmpWriter, getProgress, performCompaction
public StripeCompactor(Configuration conf, HStore store)
public java.util.List<Path> compact(CompactionRequestImpl request, java.util.List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws java.io.IOException
java.io.IOException
public java.util.List<Path> compact(CompactionRequestImpl request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws java.io.IOException
java.io.IOException
protected java.util.List<Path> commitWriter(StripeMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) throws java.io.IOException
commitWriter
in class Compactor<StripeMultiFileWriter>
java.io.IOException