@InterfaceAudience.Private class MigrationStoreFileTracker extends StoreFileTrackerBase
Modifier and Type | Field and Description |
---|---|
private StoreFileTrackerBase |
dst |
static String |
DST_IMPL |
private StoreFileTrackerBase |
src |
static String |
SRC_IMPL |
conf, ctx, isPrimaryReplica
Constructor and Description |
---|
MigrationStoreFileTracker(org.apache.hadoop.conf.Configuration conf,
boolean isPrimaryReplica,
StoreContext ctx) |
Modifier and Type | Method and 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.
|
add, createWriter, getTrackerName, load, replace, set, updateWithTrackerConfigs
public static final String SRC_IMPL
public static final String DST_IMPL
private final StoreFileTrackerBase src
private final StoreFileTrackerBase dst
public MigrationStoreFileTracker(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, StoreContext ctx)
public boolean requireWritingToTmpDirFirst()
StoreFileTracker
protected List<StoreFileInfo> doLoadStoreFiles(boolean readOnly) throws IOException
StoreFileTrackerBase
readOnly
to indicate that whether you
are allowed to do the cleanup work. For secondary replicas, we will set readOnly
to
true
.doLoadStoreFiles
in class StoreFileTrackerBase
IOException
protected void doAddNewStoreFiles(Collection<StoreFileInfo> newFiles) throws IOException
doAddNewStoreFiles
in class StoreFileTrackerBase
IOException
protected void doAddCompactionResults(Collection<StoreFileInfo> compactedFiles, Collection<StoreFileInfo> newFiles) throws IOException
doAddCompactionResults
in class StoreFileTrackerBase
IOException
protected void doSetStoreFiles(Collection<StoreFileInfo> files) throws IOException
doSetStoreFiles
in class StoreFileTrackerBase
IOException
static Class<? extends StoreFileTracker> getSrcTrackerClass(org.apache.hadoop.conf.Configuration conf)
static Class<? extends StoreFileTracker> getDstTrackerClass(org.apache.hadoop.conf.Configuration conf)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.