Field Detail

• stripeRequest

  private StripeCompactionPolicy.StripeCompactionRequest stripeRequest

Constructor Detail

• StripeStoreEngine.StripeCompaction

  private StripeStoreEngine.StripeCompaction()

Method Detail

• preSelect

  public List<StoreFile> preSelect(List<StoreFile> filesCompacting)

  Description copied from class: CompactionContext
  Called before coprocessor preCompactSelection and should filter the candidates for coprocessor; i.e. exclude the files that definitely cannot be compacted at this time.

  Specified by:

  preSelect in class CompactionContext

  Parameters:

  filesCompacting - files currently compacting

  Returns:

  the list of files that can theoretically be compacted.

• select

  public boolean select(List<StoreFile> filesCompacting,
               boolean isUserCompaction,
               boolean mayUseOffPeak,
               boolean forceMajor)
                 throws IOException

  Description copied from class: CompactionContext
  Called to select files for compaction. Must fill in the request field if successful.

  Specified by:

  select in class CompactionContext

  Parameters:

  filesCompacting - Files currently being compacted by other compactions.

  isUserCompaction - Whether this is a user compaction.

  mayUseOffPeak - Whether the underlying policy may assume it's off-peak hours.

  forceMajor - Whether to force major compaction.

  Returns:

  Whether the selection succeeded. Selection may be empty and lead to no compaction.

  Throws:

  IOException

• forceSelect

  public void forceSelect(CompactionRequest request)

  Description copied from class: CompactionContext
  Forces external selection to be applied for this compaction.

  Overrides:

  forceSelect in class CompactionContext

  Parameters:

  request - The pre-cooked request with selection and other settings.

• compact

  public List<org.apache.hadoop.fs.Path> compact(CompactionThroughputController throughputController)
                                          throws IOException

  Description copied from class: CompactionContext
  Runs the compaction based on current selection. select/forceSelect must have been called.

  Specified by:

  compact in class CompactionContext

  Returns:

  The new file paths resulting from compaction.

  Throws:

  IOException

• compact

  public List<org.apache.hadoop.fs.Path> compact(CompactionThroughputController throughputController,
                                        User user)
                                          throws IOException

  Specified by:

  compact in class CompactionContext

  Throws:

  IOException