org.apache.hadoop.hbase.regionserver

Class StripeStoreEngine

java.lang.Object

org.apache.hadoop.hbase.regionserver.StoreEngine<StripeStoreFlusher,StripeCompactionPolicy,StripeCompactor,StripeStoreFileManager>

org.apache.hadoop.hbase.regionserver.StripeStoreEngine

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class StripeStoreEngine
extends StoreEngine<StripeStoreFlusher,StripeCompactionPolicy,StripeCompactor,StripeStoreFileManager>

The storage engine that implements the stripe-based store/compaction scheme.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	StripeStoreEngine.StripeCompaction Represents one instance of stripe compaction, with the necessary context and flow.

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.StoreEngine

StoreEngine.IOExceptionRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private StripeStoreConfig	config
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreEngine

compactionPolicy, compactor, STORE_ENGINE_CLASS_KEY, storeFileManager, storeFlusher

Constructor Summary

Constructors

Constructor and Description
StripeStoreEngine()

Method Summary

Modifier and Type	Method and Description
CompactionContext	createCompaction() Creates an instance of a compaction context specific to this engine.
protected void	createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator comparator) Create the StoreEngine's components.
boolean	needsCompaction(List<HStoreFile> filesCompacting)

Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreEngine

addStoreFiles, commitStoreFiles, create, createComponentsOnce, createStoreFileAndReader, createStoreFileAndReader, createWriter, getBloomFilterMetrics, getCompactionPolicy, getCompactor, getLock, getStoreFileManager, getStoreFlusher, initialize, readLock, readUnlock, refreshStoreFiles, refreshStoreFiles, removeCompactedFiles, replaceStoreFiles, requireWritingToTmpDirFirst, validateStoreFile, writeLock, writeUnlock

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

config

private StripeStoreConfig config

Constructor Detail

StripeStoreEngine

public StripeStoreEngine()

Method Detail

needsCompaction

public boolean needsCompaction(List<HStoreFile> filesCompacting)

Specified by:

needsCompaction in class StoreEngine<StripeStoreFlusher,StripeCompactionPolicy,StripeCompactor,StripeStoreFileManager>

Parameters:

filesCompacting - Files currently compacting

Returns:

whether a compaction selection is possible

createCompaction

public CompactionContext createCompaction()

Description copied from class: StoreEngine

Creates an instance of a compaction context specific to this engine. Doesn't actually select or start a compaction. See CompactionContext class comment.

Specified by:

createCompaction in class StoreEngine<StripeStoreFlusher,StripeCompactionPolicy,StripeCompactor,StripeStoreFileManager>

Returns:

New CompactionContext object.

createComponents

protected void createComponents(org.apache.hadoop.conf.Configuration conf,
                                HStore store,
                                CellComparator comparator)
                         throws IOException

Description copied from class: StoreEngine

Create the StoreEngine's components.

Specified by:

createComponents in class StoreEngine<StripeStoreFlusher,StripeCompactionPolicy,StripeCompactor,StripeStoreFileManager>

Throws:

IOException