Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

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 RatioBasedCompactionPolicy

  Parameters:

  candidateFiles - candidate files, ordered from oldest to newest. All files in store.

  Returns:

  subset copy of candidate list that meets compaction criteria

  Throws:

  IOException

• isMajorCompaction

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

  Overrides:

  isMajorCompaction 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)

  Overrides:

  needsCompaction in class RatioBasedCompactionPolicy

• isEmptyStoreFile

  private boolean isEmptyStoreFile(StoreFile sf)

  The FIFOCompactionPolicy only choose those TTL expired HFiles as the compaction candidates. So if all HFiles are TTL expired, then the compaction will generate a new empty HFile. While its max timestamp will be Long.MAX_VALUE. If not considered separately, the HFile will never be archived because its TTL will be never expired. So we'll check the empty store file separately. (See HBASE-21504)

• hasExpiredStores

  private boolean hasExpiredStores(Collection<StoreFile> files)

• getExpiredStores

  private Collection<StoreFile> getExpiredStores(Collection<StoreFile> files,
                                       Collection<StoreFile> filesCompacting)