@InterfaceAudience.Private class DefaultStoreFileTracker extends StoreFileTrackerBase
conf, ctx, isPrimaryReplica
Constructor and Description |
---|
DefaultStoreFileTracker(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) |
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 DefaultStoreFileTracker(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, StoreContext ctx)
public boolean requireWritingToTmpDirFirst()
StoreFileTracker
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 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 doSetStoreFiles(Collection<StoreFileInfo> files) throws IOException
doSetStoreFiles
in class StoreFileTrackerBase
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.