org.apache.hadoop.hbase.regionserver.compactions

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

Fields

Modifier and Type	Field and Description
private byte[]	endRow
private byte[]	startRow
private int	targetCount
private long	targetKvs

Fields inherited from class org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy.StripeCompactionRequest

majorRangeFromRow, majorRangeToRow, request

Constructor Summary

Constructors

Constructor and Description
SplitStripeCompactionRequest(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 Type	Method and Description
List<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	setMajorRangeFull() 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

startRow

private final byte[] startRow

endRow

private final byte[] endRow

targetCount

private final int targetCount

targetKvs

private final long targetKvs

Constructor Detail

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 Detail

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 class StripeCompactionPolicy.StripeCompactionRequest

Parameters:

compactor - Compactor.

Returns:

result of compact(...)

Throws:

IOException

setMajorRangeFull

public void setMajorRangeFull()

Set major range of the compaction to the entire compaction range. See StripeCompactionPolicy.StripeCompactionRequest.setMajorRange(byte[], byte[]).