private static class StripeCompactionPolicy.BoundaryStripeCompactionRequest extends StripeCompactionPolicy.StripeCompactionRequest
| Modifier and Type | Field and Description |
|---|---|
private List<byte[]> |
targetBoundaries |
majorRangeFromRow, majorRangeToRow, request| Constructor and Description |
|---|
StripeCompactionPolicy.BoundaryStripeCompactionRequest(Collection<StoreFile> files,
List<byte[]> targetBoundaries) |
StripeCompactionPolicy.BoundaryStripeCompactionRequest(CompactionRequest request,
List<byte[]> targetBoundaries) |
| 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.
|
execute, getRequest, setMajorRange, setRequestprivate final List<byte[]> targetBoundaries
public StripeCompactionPolicy.BoundaryStripeCompactionRequest(CompactionRequest request, List<byte[]> targetBoundaries)
request - Original request.targetBoundaries - New files should be written with these boundaries.public StripeCompactionPolicy.BoundaryStripeCompactionRequest(Collection<StoreFile> files, List<byte[]> targetBoundaries)
public List<org.apache.hadoop.fs.Path> execute(StripeCompactor compactor, CompactionThroughputController throughputController, User user) throws IOException
StripeCompactionPolicy.StripeCompactionRequestexecute in class StripeCompactionPolicy.StripeCompactionRequestcompactor - Compactor.IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.