Package org.apache.hadoop.hbase.regionserver.storefiletracker

Class MigrationStoreFileTracker

java.lang.Object

org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerBase

org.apache.hadoop.hbase.regionserver.storefiletracker.MigrationStoreFileTracker

All Implemented Interfaces:

StoreFileTracker

@Private
class MigrationStoreFileTracker
extends StoreFileTrackerBase

A store file tracker used for migrating between store file tracker implementations.

Field Summary

Fields

Modifier and Type	Field	Description
private final StoreFileTrackerBase	dst
static final String	DST_IMPL
private final StoreFileTrackerBase	src
static final String	SRC_IMPL

Fields inherited from class org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerBase

conf, ctx, isPrimaryReplica

Constructor Summary

Constructors

Constructor	Description
MigrationStoreFileTracker(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, StoreContext ctx)

Method Summary

Modifier and Type	Method	Description
protected void	doAddCompactionResults(Collection<StoreFileInfo> compactedFiles, Collection<StoreFileInfo> newFiles)
protected void	doAddNewStoreFiles(Collection<StoreFileInfo> newFiles)
protected List<StoreFileInfo>	doLoadStoreFiles(boolean readOnly)	For primary replica, we will call load once when opening a region, and the implementation could choose to do some cleanup work.
protected void	doSetStoreFiles(Collection<StoreFileInfo> files)
(package private) static Class<? extends StoreFileTracker>	getDstTrackerClass(org.apache.hadoop.conf.Configuration conf)
(package private) static Class<? extends StoreFileTracker>	getSrcTrackerClass(org.apache.hadoop.conf.Configuration conf)
boolean	requireWritingToTmpDirFirst()	Whether the implementation of this tracker requires you to write to temp directory first, i.e, does not allow broken store files under the actual data directory.

Methods inherited from class org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerBase

add, createReference, createWriter, getStoreFileInfo, getStoreFileInfo, getTrackerName, hasReferences, load, readReference, replace, set, updateWithTrackerConfigs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SRC_IMPL

public static final String SRC_IMPL

See Also:

• Constant Field Values

DST_IMPL

public static final String DST_IMPL

See Also:

• Constant Field Values

src

private final StoreFileTrackerBase src

dst

private final StoreFileTrackerBase dst

Constructor Details

MigrationStoreFileTracker

public MigrationStoreFileTracker(org.apache.hadoop.conf.Configuration conf,
 boolean isPrimaryReplica,
 StoreContext ctx)

Method Details

requireWritingToTmpDirFirst

public boolean requireWritingToTmpDirFirst()

Description copied from interface: StoreFileTracker

Whether the implementation of this tracker requires you to write to temp directory first, i.e, does not allow broken store files under the actual data directory.

doLoadStoreFiles

protected List<StoreFileInfo> doLoadStoreFiles(boolean readOnly)
                                        throws IOException

Description copied from class: StoreFileTrackerBase

For primary replica, we will call load once when opening a region, and the implementation could choose to do some cleanup work. So here we use readOnly to indicate that whether you are allowed to do the cleanup work. For secondary replicas, we will set readOnly to true.

Specified by:

doLoadStoreFiles in class StoreFileTrackerBase

Throws:

IOException

doAddNewStoreFiles

protected void doAddNewStoreFiles(Collection<StoreFileInfo> newFiles)
                           throws IOException

Specified by:

doAddNewStoreFiles in class StoreFileTrackerBase

Throws:

IOException

doAddCompactionResults

protected void doAddCompactionResults(Collection<StoreFileInfo> compactedFiles,
 Collection<StoreFileInfo> newFiles)
                               throws IOException

Specified by:

doAddCompactionResults in class StoreFileTrackerBase

Throws:

IOException

doSetStoreFiles

protected void doSetStoreFiles(Collection<StoreFileInfo> files)
                        throws IOException

Specified by:

doSetStoreFiles in class StoreFileTrackerBase

Throws:

IOException

getSrcTrackerClass

static Class<? extends StoreFileTracker> getSrcTrackerClass(org.apache.hadoop.conf.Configuration conf)

getDstTrackerClass

static Class<? extends StoreFileTracker> getDstTrackerClass(org.apache.hadoop.conf.Configuration conf)