@InterfaceAudience.Private class FileBasedStoreFileTracker extends StoreFileTrackerBase
Modifier and Type | Field and Description |
---|---|
private StoreFileListFile |
backedFile |
private Map<String,StoreFileInfo> |
storefiles |
conf, ctx, isPrimaryReplica
Constructor and Description |
---|
FileBasedStoreFileTracker(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.
|
private org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileEntry |
toStoreFileEntry(StoreFileInfo info) |
add, createWriter, getTrackerName, load, replace, set, updateWithTrackerConfigs
private final StoreFileListFile backedFile
private final Map<String,StoreFileInfo> storefiles
public FileBasedStoreFileTracker(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, StoreContext ctx)
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
public boolean requireWritingToTmpDirFirst()
StoreFileTracker
private org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileEntry toStoreFileEntry(StoreFileInfo info)
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
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.