org.apache.hadoop.hbase.regionserver

Class StripeStoreFileManager.CompactionOrFlushMergeCopy

java.lang.Object

org.apache.hadoop.hbase.regionserver.StripeStoreFileManager.CompactionOrFlushMergeCopy

Enclosing class:

StripeStoreFileManager

private class StripeStoreFileManager.CompactionOrFlushMergeCopy
extends Object

Non-static helper class for merging compaction or flush results. Since we want to merge them atomically (more or less), it operates on lazy copies, then creates a new state object and puts it in place.

Field Summary

Fields

Modifier and Type	Field and Description
private Collection<HStoreFile>	compactedFiles
private boolean	isFlush
private List<HStoreFile>	l0Results
private ArrayList<HStoreFile>	level0Files
private Collection<HStoreFile>	results
private ArrayList<byte[]>	stripeEndRows
private ArrayList<List<HStoreFile>>	stripeFiles

Constructor Summary

Constructors

Constructor and Description
CompactionOrFlushMergeCopy(boolean isFlush)

Method Summary

Modifier and Type	Method and Description
private StripeStoreFileManager.State	createNewState(boolean delCompactedFiles)
private void	deleteResults(Collection<HStoreFile> compactedFiles)
private ArrayList<HStoreFile>	getLevel0Copy()
private ArrayList<HStoreFile>	getStripeCopy(int index)
private void	mergeResults(Collection<HStoreFile> compactedFiles, Collection<HStoreFile> results)
private void	processNewCandidateStripes(TreeMap<byte[],HStoreFile> newStripes) See StripeStoreFileManager.addCompactionResults(Collection, Collection) - updates the stripe list with new candidate stripes/removes old stripes; produces new set of stripe end rows.
private TreeMap<byte[],HStoreFile>	processResults() Process new files, and add them either to the structure of existing stripes, or to the list of new candidate stripes.
private void	removeCompactedFiles() Remove compacted files.
private void	updateMetadataMaps()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

stripeFiles

private ArrayList<List<HStoreFile>> stripeFiles

level0Files

private ArrayList<HStoreFile> level0Files

stripeEndRows

private ArrayList<byte[]> stripeEndRows

compactedFiles

private Collection<HStoreFile> compactedFiles

results

private Collection<HStoreFile> results

l0Results

private List<HStoreFile> l0Results

isFlush

private final boolean isFlush

Constructor Detail

CompactionOrFlushMergeCopy

public CompactionOrFlushMergeCopy(boolean isFlush)

Method Detail

mergeResults

private void mergeResults(Collection<HStoreFile> compactedFiles,
                          Collection<HStoreFile> results)
                   throws IOException

Throws:

IOException

deleteResults

private void deleteResults(Collection<HStoreFile> compactedFiles)
                    throws IOException

Throws:

IOException

createNewState

private StripeStoreFileManager.State createNewState(boolean delCompactedFiles)

updateMetadataMaps

private void updateMetadataMaps()

getStripeCopy

private final ArrayList<HStoreFile> getStripeCopy(int index)

Parameters:

index - Index of the stripe we need.

Returns:

A lazy stripe copy from current stripes.

getLevel0Copy

private final ArrayList<HStoreFile> getLevel0Copy()

Returns:

A lazy L0 copy from current state.

processResults

private TreeMap<byte[],HStoreFile> 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.

Throws:

IOException

processNewCandidateStripes

private void processNewCandidateStripes(TreeMap<byte[],HStoreFile> 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