org.apache.hadoop.hbase.regionserver

Class DefaultStoreEngine

java.lang.Object

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

org.apache.hadoop.hbase.regionserver.DefaultStoreEngine

Direct Known Subclasses:

MobStoreEngine

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_COMPACTION_POLICY_CLASS_KEY
static java.lang.String	DEFAULT_COMPACTOR_CLASS_KEY
static java.lang.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(Configuration conf, Store store)
protected void	createCompactor(Configuration conf, Store store)
protected void	createComponents(Configuration conf, Store store, KeyValue.KVComparator kvComparator) Create the StoreEngine's components.
protected void	createStoreFlusher(Configuration conf, Store store)
boolean	needsCompaction(java.util.List<StoreFile> filesCompacting)

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

create, getCompactionPolicy, getCompactor, getStoreFileManager, getStoreFlusher

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 java.lang.String DEFAULT_STORE_FLUSHER_CLASS_KEY

See Also:

Constant Field Values

DEFAULT_COMPACTOR_CLASS_KEY

public static final java.lang.String DEFAULT_COMPACTOR_CLASS_KEY

See Also:

Constant Field Values

DEFAULT_COMPACTION_POLICY_CLASS_KEY

public static final java.lang.String DEFAULT_COMPACTION_POLICY_CLASS_KEY

See Also:

Constant Field Values

Constructor Detail

DefaultStoreEngine

public DefaultStoreEngine()

Method Detail

needsCompaction

public boolean needsCompaction(java.util.List<StoreFile> filesCompacting)

Specified by:

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

Parameters:

filesCompacting - Files currently compacting

Returns:

whether a compaction selection is possible

createComponents

protected void createComponents(Configuration conf,
                                Store store,
                                KeyValue.KVComparator kvComparator)
                         throws java.io.IOException

Description copied from class: StoreEngine

Create the StoreEngine's components.

Specified by:

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

Throws:

java.io.IOException

createCompactor

protected void createCompactor(Configuration conf,
                               Store store)
                        throws java.io.IOException

Throws:

java.io.IOException

createCompactionPolicy

protected void createCompactionPolicy(Configuration conf,
                                      Store store)
                               throws java.io.IOException

Throws:

java.io.IOException

createStoreFlusher

protected void createStoreFlusher(Configuration conf,
                                  Store store)
                           throws java.io.IOException

Throws:

java.io.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,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>

Returns:

New CompactionContext object.