Constructor Detail

• FIFOCompactionPolicy

  public FIFOCompactionPolicy(org.apache.hadoop.conf.Configuration conf,
                      StoreConfigInformation storeConfigInfo)

Method Detail

• selectCompaction

  public CompactionRequest selectCompaction(Collection<StoreFile> candidateFiles,
                                   List<StoreFile> filesCompacting,
                                   boolean isUserCompaction,
                                   boolean mayUseOffPeak,
                                   boolean forceMajor)
                                     throws IOException

  Overrides:

  selectCompaction in class SortedCompactionPolicy

  Parameters:

  candidateFiles - candidate files, ordered from oldest to newest by seqId. We rely on DefaultStoreFileManager to sort the files by seqId to guarantee contiguous compaction based on seqId for data consistency.

  Returns:

  subset copy of candidate list that meets compaction criteria

  Throws:

  IOException

• shouldPerformMajorCompaction

  public boolean shouldPerformMajorCompaction(Collection<StoreFile> filesToCompact)
                                       throws IOException

  Overrides:

  shouldPerformMajorCompaction in class RatioBasedCompactionPolicy

  Parameters:

  filesToCompact - Files to compact. Can be null.

  Returns:

  True if we should run a major compaction.

  Throws:

  IOException

• needsCompaction

  public boolean needsCompaction(Collection<StoreFile> storeFiles,
                        List<StoreFile> filesCompacting)

  Description copied from class: RatioBasedCompactionPolicy
  A heuristic method to decide whether to schedule a compaction request

  Overrides:

  needsCompaction in class RatioBasedCompactionPolicy

  Parameters:

  storeFiles - files in the store.

  filesCompacting - files being scheduled to compact.

  Returns:

  true to schedule a request.