private static class StripeCompactionPolicy.SplitStripeCompactionRequest extends StripeCompactionPolicy.StripeCompactionRequest
| Modifier and Type | Field and Description |
|---|---|
private byte[] |
endRow |
private byte[] |
startRow |
private int |
targetCount |
private long |
targetKvs |
majorRangeFromRow, majorRangeToRow, request| Constructor and Description |
|---|
StripeCompactionPolicy.SplitStripeCompactionRequest(Collection<StoreFile> files,
byte[] startRow,
byte[] endRow,
int targetCount,
long targetKvs) |
StripeCompactionPolicy.SplitStripeCompactionRequest(Collection<StoreFile> files,
byte[] startRow,
byte[] endRow,
long targetKvs) |
StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request,
byte[] startRow,
byte[] endRow,
int targetCount,
long targetKvs) |
StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request,
byte[] startRow,
byte[] endRow,
long targetKvs) |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.hadoop.fs.Path> |
execute(StripeCompactor compactor,
CompactionThroughputController throughputController,
User user)
Executes the request against compactor (essentially, just calls correct overload of
compact method), to simulate more dynamic dispatch.
|
void |
setMajorRangeFull()
Set major range of the compaction to the entire compaction range.
|
execute, getRequest, setMajorRange, setRequestprivate final byte[] startRow
private final byte[] endRow
private final int targetCount
private final long targetKvs
public StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request, byte[] startRow, byte[] endRow, int targetCount, long targetKvs)
request - Original request.startRow - Left boundary of the range to compact, inclusive.endRow - Right boundary of the range to compact, exclusive.targetCount - The maximum number of stripe to compact into.targetKvs - The KV count of each segment. If targetKvs*targetCount is less than
total number of kvs, all the overflow data goes into the last stripe.public StripeCompactionPolicy.SplitStripeCompactionRequest(CompactionRequest request, byte[] startRow, byte[] endRow, long targetKvs)
public StripeCompactionPolicy.SplitStripeCompactionRequest(Collection<StoreFile> files, byte[] startRow, byte[] endRow, long targetKvs)
public StripeCompactionPolicy.SplitStripeCompactionRequest(Collection<StoreFile> files, byte[] startRow, byte[] endRow, int targetCount, long targetKvs)
public List<org.apache.hadoop.fs.Path> execute(StripeCompactor compactor, CompactionThroughputController throughputController, User user) throws IOException
StripeCompactionPolicy.StripeCompactionRequestexecute in class StripeCompactionPolicy.StripeCompactionRequestcompactor - Compactor.IOExceptionpublic void setMajorRangeFull()
StripeCompactionPolicy.StripeCompactionRequest.setMajorRange(byte[], byte[]).Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.