@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 String |
DEFAULT_COMPACTION_POLICY_CLASS_KEY |
static String |
DEFAULT_COMPACTOR_CLASS_KEY |
static 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(List<StoreFile> filesCompacting) |
create, getCompactionPolicy, getCompactor, getStoreFileManager, getStoreFlusherpublic static final String DEFAULT_STORE_FLUSHER_CLASS_KEY
public static final String DEFAULT_COMPACTOR_CLASS_KEY
public static final String DEFAULT_COMPACTION_POLICY_CLASS_KEY
public boolean needsCompaction(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 IOException
StoreEnginecreateComponents in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>IOExceptionprotected void createCompactor(Configuration conf,
Store store)
throws IOException
IOExceptionprotected void createCompactionPolicy(Configuration conf,
Store store)
throws IOException
IOExceptionprotected void createStoreFlusher(Configuration conf,
Store store)
throws IOException
IOExceptionpublic CompactionContext createCompaction()
StoreEnginecreateCompaction in class StoreEngine<DefaultStoreFlusher,RatioBasedCompactionPolicy,DefaultCompactor,org.apache.hadoop.hbase.regionserver.DefaultStoreFileManager>