Field Detail

• request

  protected CompactionRequest request

• majorRangeFromRow

  protected byte[] majorRangeFromRow

• majorRangeToRow

  protected byte[] majorRangeToRow

Constructor Detail

• StripeCompactionPolicy.StripeCompactionRequest

  public StripeCompactionPolicy.StripeCompactionRequest(CompactionRequest request)

Method Detail

• execute

  public List<org.apache.hadoop.fs.Path> execute(StripeCompactor compactor,
                                        ThroughputController throughputController)
                                          throws IOException

  Throws:

  IOException

• execute

  public abstract List<org.apache.hadoop.fs.Path> execute(StripeCompactor compactor,
                                        ThroughputController throughputController,
                                        User user)
                                                   throws IOException

  Executes the request against compactor (essentially, just calls correct overload of compact method), to simulate more dynamic dispatch.

  Parameters:

  compactor - Compactor.

  Returns:

  result of compact(...)

  Throws:

  IOException

• setMajorRange

  public void setMajorRange(byte[] startRow,
                   byte[] endRow)

  Sets compaction "major range". Major range is the key range for which all the files are included, so they can be treated like major-compacted files.

  Parameters:

  startRow - Left boundary, inclusive.

  endRow - Right boundary, exclusive.

• getRequest

  public CompactionRequest getRequest()

• setRequest

  public void setRequest(CompactionRequest request)