org.apache.hadoop.hbase.regionserver

Class DefaultStoreEngine

java.lang.Object

org.apache.hadoop.hbase.regionserver.StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,DefaultStoreFileManager>

org.apache.hadoop.hbase.regionserver.DefaultStoreEngine

Direct Known Subclasses:

MobStoreEngine

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class DefaultStoreEngine
extends StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,DefaultStoreFileManager>

Default StoreEngine creates the default compactor, policy, and store file manager, or their derivatives.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultStoreEngine.DefaultCompactionContext

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

StoreEngine.IOExceptionRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private static Class<? extends RatioBasedCompactionPolicy>	DEFAULT_COMPACTION_POLICY_CLASS
static String	DEFAULT_COMPACTION_POLICY_CLASS_KEY
private static Class<? extends DefaultCompactor>	DEFAULT_COMPACTOR_CLASS
static String	DEFAULT_COMPACTOR_CLASS_KEY
private static Class<? extends DefaultStoreFlusher>	DEFAULT_STORE_FLUSHER_CLASS
static String	DEFAULT_STORE_FLUSHER_CLASS_KEY

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

compactionPolicy, compactor, STORE_ENGINE_CLASS_KEY, storeFileManager, storeFlusher

Constructor Summary

Constructors

Constructor and Description
DefaultStoreEngine()

Method Summary

Modifier and Type	Method and Description
CompactionContext	createCompaction() Creates an instance of a compaction context specific to this engine.
protected void	createCompactionPolicy(org.apache.hadoop.conf.Configuration conf, HStore store)
protected void	createCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
protected void	createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator kvComparator) Create the StoreEngine's components.
protected void	createStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)
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

DEFAULT_STORE_FLUSHER_CLASS_KEY

public static final String DEFAULT_STORE_FLUSHER_CLASS_KEY

See Also:

Constant Field Values

DEFAULT_COMPACTOR_CLASS_KEY

public static final String DEFAULT_COMPACTOR_CLASS_KEY

See Also:

Constant Field Values

DEFAULT_COMPACTION_POLICY_CLASS_KEY

public static final String DEFAULT_COMPACTION_POLICY_CLASS_KEY

See Also:

Constant Field Values

DEFAULT_STORE_FLUSHER_CLASS

private static final Class<? extends DefaultStoreFlusher> DEFAULT_STORE_FLUSHER_CLASS

DEFAULT_COMPACTOR_CLASS

private static final Class<? extends DefaultCompactor> DEFAULT_COMPACTOR_CLASS

DEFAULT_COMPACTION_POLICY_CLASS

private static final Class<? extends RatioBasedCompactionPolicy> DEFAULT_COMPACTION_POLICY_CLASS

Constructor Detail

DefaultStoreEngine

public DefaultStoreEngine()

Method Detail

needsCompaction

public boolean needsCompaction(List<HStoreFile> filesCompacting)

Specified by:

needsCompaction in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,DefaultStoreFileManager>

Parameters:

filesCompacting - Files currently compacting

Returns:

whether a compaction selection is possible

createComponents

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

Description copied from class: StoreEngine

Create the StoreEngine's components.

Specified by:

createComponents in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,DefaultStoreFileManager>

Throws:

IOException

createCompactor

protected void createCompactor(org.apache.hadoop.conf.Configuration conf,
                               HStore store)
                        throws IOException

Throws:

IOException

createCompactionPolicy

protected void createCompactionPolicy(org.apache.hadoop.conf.Configuration conf,
                                      HStore store)
                               throws IOException

Throws:

IOException

createStoreFlusher

protected void createStoreFlusher(org.apache.hadoop.conf.Configuration conf,
                                  HStore store)
                           throws IOException

Throws:

IOException

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<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,DefaultStoreFileManager>

Returns:

New CompactionContext object.