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
@LimitedPrivate("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
-
Field Summary
Modifier and TypeFieldDescriptionprivate static final Class<? extends RatioBasedCompactionPolicy>
static final String
private static final Class<? extends DefaultCompactor>
static final String
private static final Class<? extends DefaultStoreFlusher>
static final String
Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreEngine
compactionPolicy, compactor, STORE_ENGINE_CLASS_KEY, storeFileManager, storeFlusher
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionCreates 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
-
Field Details
-
DEFAULT_STORE_FLUSHER_CLASS_KEY
- See Also:
-
DEFAULT_COMPACTOR_CLASS_KEY
- See Also:
-
DEFAULT_COMPACTION_POLICY_CLASS_KEY
- See Also:
-
DEFAULT_STORE_FLUSHER_CLASS
-
DEFAULT_COMPACTOR_CLASS
-
DEFAULT_COMPACTION_POLICY_CLASS
-
-
Constructor Details
-
DefaultStoreEngine
public DefaultStoreEngine()
-
-
Method Details
-
needsCompaction
- Specified by:
needsCompaction
in classStoreEngine<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 classStoreEngine<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
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 classStoreEngine<DefaultStoreFlusher,
RatioBasedCompactionPolicy, DefaultCompactor, DefaultStoreFileManager> - Returns:
- New CompactionContext object.
-