@InterfaceAudience.LimitedPrivate(value="Configuration") public class DefaultStoreEngine extends StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>
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 |
compactionPolicy, compactor, STORE_ENGINE_CLASS_KEY, storeFileManager, storeFlusher
Constructor and Description |
---|
DefaultStoreEngine() |
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) |
create, getCompactionPolicy, getCompactor, getStoreFileManager, getStoreFlusher
public static final java.lang.String DEFAULT_STORE_FLUSHER_CLASS_KEY
public static final java.lang.String DEFAULT_COMPACTOR_CLASS_KEY
public static final java.lang.String DEFAULT_COMPACTION_POLICY_CLASS_KEY
public boolean needsCompaction(java.util.List<StoreFile> filesCompacting)
needsCompaction
in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>
filesCompacting
- Files currently compactingprotected void createComponents(Configuration conf, Store store, KeyValue.KVComparator kvComparator) throws java.io.IOException
StoreEngine
createComponents
in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>
java.io.IOException
protected void createCompactor(Configuration conf, Store store) throws java.io.IOException
java.io.IOException
protected void createCompactionPolicy(Configuration conf, Store store) throws java.io.IOException
java.io.IOException
protected void createStoreFlusher(Configuration conf, Store store) throws java.io.IOException
java.io.IOException
public CompactionContext createCompaction()
StoreEngine
createCompaction
in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>