Package 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	Description
private Collection<HStoreFile>	compactedFiles
private final 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	Description
CompactionOrFlushMergeCopy(boolean isFlush)

Method Summary

Modifier and Type	Method	Description
private StripeStoreFileManager.State	createNewState(boolean delCompactedFiles)
private void	deleteResults(Collection<HStoreFile> compactedFiles)
private final ArrayList<HStoreFile>	getLevel0Copy()	Returns A lazy L0 copy from current state.
private final 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 Details

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 Details

CompactionOrFlushMergeCopy

public CompactionOrFlushMergeCopy(boolean isFlush)

Method Details

mergeResults

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

deleteResults

private void deleteResults(Collection<HStoreFile> compactedFiles)

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

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.

removeCompactedFiles

private void removeCompactedFiles()

Remove compacted files.

processNewCandidateStripes

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.

Parameters:

newStripes - New stripes - files by end row.