@InterfaceAudience.Private public class StripeCompactor extends Compactor
Compactor.CellSink, Compactor.FileDetails| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
compactionCompression, conf, keepSeqIdPeriod, progress, store| Constructor and Description |
|---|
StripeCompactor(org.apache.hadoop.conf.Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequest request,
List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
private List<org.apache.hadoop.fs.Path> |
compactInternal(StripeMultiFileWriter mw,
CompactionRequest request,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
createFileScanners, createScanner, createScanner, getFileDetails, getProgress, getSmallestReadPoint, performCompaction, postCreateCoprocScanner, preCreateCoprocScanner, preCreateCoprocScannerpublic 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, CompactionThroughputController throughputController) throws IOException
IOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController, User user) throws IOException
IOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController) throws IOException
IOExceptionpublic List<org.apache.hadoop.fs.Path> compact(CompactionRequest request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController, User user) throws IOException
IOExceptionprivate List<org.apache.hadoop.fs.Path> compactInternal(StripeMultiFileWriter mw, CompactionRequest request, byte[] majorRangeFromRow, byte[] majorRangeToRow, CompactionThroughputController throughputController, User user) throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.