Field Detail

• stripeFiles

  private ArrayList<List<StoreFile>> stripeFiles

• level0Files

  private ArrayList<StoreFile> level0Files

• stripeEndRows

  private ArrayList<byte[]> stripeEndRows

• compactedFiles

  private Collection<StoreFile> compactedFiles

• results

  private Collection<StoreFile> results

• l0Results

  private List<StoreFile> l0Results

• isFlush

  private final boolean isFlush

Constructor Detail

• StripeStoreFileManager.CompactionOrFlushMergeCopy

  public StripeStoreFileManager.CompactionOrFlushMergeCopy(boolean isFlush)

Method Detail

• mergeResults

  public void mergeResults(Collection<StoreFile> compactedFiles,
                  Collection<StoreFile> results)
                    throws IOException

  Throws:

  IOException

• createNewState

  private StripeStoreFileManager.State createNewState()

• updateMetadataMaps

  private void updateMetadataMaps()

• getStripeCopy

  private final ArrayList<StoreFile> getStripeCopy(int index)

  Parameters:

  index - Index of the stripe we need.

  Returns:

  A lazy stripe copy from current stripes.

• getLevel0Copy

  private final ArrayList<StoreFile> getLevel0Copy()

  Returns:

  A lazy L0 copy from current state.

• processResults

  private TreeMap<byte[],StoreFile> processResults()
                                            throws IOException

  Process new files, and add them either to the structure of existing stripes, or to the list of new candidate stripes.

  Returns:

  New candidate stripes.

  Throws:

  IOException

• removeCompactedFiles

  private void removeCompactedFiles()
                             throws IOException

  Remove compacted files.

  Parameters:

  compactedFiles - Compacted files.

  Throws:

  IOException

• processNewCandidateStripes

  private void processNewCandidateStripes(TreeMap<byte[],StoreFile> newStripes)
                                   throws IOException

  See StripeStoreFileManager.addCompactionResults(Collection, Collection) - updates the stripe list with new candidate stripes/removes old stripes; produces new set of stripe end rows.

  Parameters:

  newStripes - New stripes - files by end row.

  Throws:

  IOException