Field Detail

• storeFlusher

  protected SF extends StoreFlusher storeFlusher

• compactionPolicy

  protected CP extends CompactionPolicy compactionPolicy

• compactor

  protected C extends Compactor compactor

• storeFileManager

  protected SFM extends StoreFileManager storeFileManager

• STORE_ENGINE_CLASS_KEY

  public static final String STORE_ENGINE_CLASS_KEY

  The name of the configuration parameter that specifies the class of a store engine that is used to manage and compact HBase store files.

  See Also:

  Constant Field Values

• DEFAULT_STORE_ENGINE_CLASS

  private static final Class<? extends StoreEngine<?,?,?,?>> DEFAULT_STORE_ENGINE_CLASS

Constructor Detail

• StoreEngine

  public StoreEngine()

Method Detail

• getCompactionPolicy

  public CompactionPolicy getCompactionPolicy()

  Returns:

  Compaction policy to use.

• getCompactor

  public Compactor getCompactor()

  Returns:

  Compactor to use.

• getStoreFileManager

  public StoreFileManager getStoreFileManager()

  Returns:

  Store file manager to use.

• getStoreFlusher

  public StoreFlusher getStoreFlusher()

  Returns:

  Store flusher to use.

• needsCompaction

  public abstract boolean needsCompaction(List<StoreFile> filesCompacting)

  Parameters:

  filesCompacting - Files currently compacting

  Returns:

  whether a compaction selection is possible

• createCompaction

  public abstract CompactionContext createCompaction()
                                              throws IOException

  Creates an instance of a compaction context specific to this engine. Doesn't actually select or start a compaction. See CompactionContext class comment.

  Returns:

  New CompactionContext object.

  Throws:

  IOException

• createComponents

  protected abstract void createComponents(org.apache.hadoop.conf.Configuration conf,
                      Store store,
                      KeyValue.KVComparator kvComparator)
                                    throws IOException

  Create the StoreEngine's components.

  Throws:

  IOException

• createComponentsOnce

  private void createComponentsOnce(org.apache.hadoop.conf.Configuration conf,
                          Store store,
                          KeyValue.KVComparator kvComparator)
                             throws IOException

  Throws:

  IOException

• create

  public static StoreEngine<?,?,?,?> create(Store store,
                            org.apache.hadoop.conf.Configuration conf,
                            KeyValue.KVComparator kvComparator)
                                     throws IOException

  Create the StoreEngine configured for the given Store.

  Parameters:

  store - The store. An unfortunate dependency needed due to it being passed to coprocessors via the compactor.

  conf - Store configuration.

  kvComparator - KVComparator for storeFileManager.

  Returns:

  StoreEngine to use.

  Throws:

  IOException