@InterfaceAudience.Private public class StripeCompactor extends AbstractMultiOutputCompactor<StripeMultiFileWriter>
Compactor.CellSink, Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
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,
Store store) |
Modifier and Type | Method and Description |
---|---|
protected List<org.apache.hadoop.fs.Path> |
commitWriter(StripeMultiFileWriter writer,
Compactor.FileDetails fd,
CompactionRequest request) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
ThroughputController throughputController,
User user) |
abortWriter, initMultiWriter
compact, createFileScanners, createScanner, createScanner, createTmpWriter, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner
public StripeCompactor(org.apache.hadoop.conf.Configuration conf, Store store)
public List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws IOException
IOException
public List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user) throws IOException
IOException
protected List<org.apache.hadoop.fs.Path> commitWriter(StripeMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequest request) throws IOException
commitWriter
in class Compactor<StripeMultiFileWriter>
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.