@InterfaceAudience.Private public class StripeCompactor extends AbstractMultiOutputCompactor<StripeMultiFileWriter>
| Modifier and Type | Class and Description | 
|---|---|
| private class  | StripeCompactor.StripeInternalScannerFactory | 
Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory| Modifier and Type | Field and Description | 
|---|---|
| private static org.slf4j.Logger | LOG | 
COMPACTION_PROGRESS_LOG_INTERVAL, compactionCompression, compactionKVMax, conf, defaultScannerFactory, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, MINOR_COMPACTION_DROP_CACHE, progress, store| Constructor and Description | 
|---|
| StripeCompactor(org.apache.hadoop.conf.Configuration conf,
               HStore store) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected List<org.apache.hadoop.fs.Path> | commitWriter(StripeMultiFileWriter writer,
            Compactor.FileDetails fd,
            CompactionRequestImpl request) | 
| List<org.apache.hadoop.fs.Path> | compact(CompactionRequestImpl request,
       int targetCount,
       long targetSize,
       byte[] left,
       byte[] right,
       byte[] majorRangeFromRow,
       byte[] majorRangeToRow,
       ThroughputController throughputController,
       User user) | 
| List<org.apache.hadoop.fs.Path> | compact(CompactionRequestImpl request,
       List<byte[]> targetBoundaries,
       byte[] majorRangeFromRow,
       byte[] majorRangeToRow,
       ThroughputController throughputController,
       User user) | 
abortWriter, initMultiWritercompact, createScanner, createScanner, createTmpWriter, getProgress, performCompactionprivate static final org.slf4j.Logger LOG
public StripeCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
public List<org.apache.hadoop.fs.Path> compact(CompactionRequestImpl request, List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws IOException
IOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionRequestImpl request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws IOException
IOExceptionprotected List<org.apache.hadoop.fs.Path> commitWriter(StripeMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) throws IOException
commitWriter in class Compactor<StripeMultiFileWriter>IOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.