Class StripeCompactionPolicy.SplitStripeCompactionRequest
java.lang.Object
org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy.StripeCompactionRequest
org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy.SplitStripeCompactionRequest
- Enclosing class:
- StripeCompactionPolicy
private static class StripeCompactionPolicy.SplitStripeCompactionRequest
extends StripeCompactionPolicy.StripeCompactionRequest
Request for stripe compactor that will cause it to split the source files into several separate
files into based on key-value count, as well as file count limit. Most of the files will be
roughly the same size. The last file may be smaller or larger depending on the interplay of the
amount of data and maximum number of files allowed.
-
Field Summary
Modifier and TypeFieldDescriptionprivate final byte[]
private final byte[]
private final int
private final long
Fields inherited from class org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy.StripeCompactionRequest
majorRangeFromRow, majorRangeToRow, request
-
Constructor Summary
ConstructorDescriptionSplitStripeCompactionRequest
(Collection<HStoreFile> files, byte[] startRow, byte[] endRow, int targetCount, long targetKvs) SplitStripeCompactionRequest
(Collection<HStoreFile> files, byte[] startRow, byte[] endRow, long targetKvs) SplitStripeCompactionRequest
(CompactionRequestImpl request, byte[] startRow, byte[] endRow, int targetCount, long targetKvs) -
Method Summary
Modifier and TypeMethodDescriptionList<org.apache.hadoop.fs.Path>
execute
(StripeCompactor compactor, ThroughputController throughputController, User user) Executes the request against compactor (essentially, just calls correct overload of compact method), to simulate more dynamic dispatch.void
Set major range of the compaction to the entire compaction range.Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy.StripeCompactionRequest
execute, getRequest, setMajorRange, setRequest
-
Field Details
-
startRow
-
endRow
-
targetCount
-
targetKvs
-
-
Constructor Details
-
SplitStripeCompactionRequest
public SplitStripeCompactionRequest(CompactionRequestImpl request, byte[] startRow, byte[] endRow, int targetCount, long targetKvs) - Parameters:
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.
-
SplitStripeCompactionRequest
public SplitStripeCompactionRequest(Collection<HStoreFile> files, byte[] startRow, byte[] endRow, long targetKvs) -
SplitStripeCompactionRequest
public SplitStripeCompactionRequest(Collection<HStoreFile> files, byte[] startRow, byte[] endRow, int targetCount, long targetKvs)
-
-
Method Details
-
execute
public List<org.apache.hadoop.fs.Path> execute(StripeCompactor compactor, ThroughputController throughputController, User user) throws IOException Description copied from class:StripeCompactionPolicy.StripeCompactionRequest
Executes the request against compactor (essentially, just calls correct overload of compact method), to simulate more dynamic dispatch.- Specified by:
execute
in classStripeCompactionPolicy.StripeCompactionRequest
- Parameters:
compactor
- Compactor.- Returns:
- result of compact(...)
- Throws:
IOException
-
setMajorRangeFull
Set major range of the compaction to the entire compaction range. SeeStripeCompactionPolicy.StripeCompactionRequest.setMajorRange(byte[], byte[])
.
-