public class SnapshotHFileCleaner extends BaseHFileCleanerDelegate
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HFILE_CACHE_REFRESH_PERIOD_CONF_KEY
Conf key for the frequency to attempt to refresh the cache of hfiles currently used in
snapshots (ms)
|
Constructor and Description |
---|
SnapshotHFileCleaner() |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<FileStatus> |
getDeletableFiles(java.lang.Iterable<FileStatus> files)
Determines which of the given files are safe to delete
|
SnapshotFileCache |
getFileCacheForTesting()
Exposed for Testing!
|
void |
init(java.util.Map<java.lang.String,java.lang.Object> params)
this method is used to pass some instance into subclass
|
protected boolean |
isFileDeletable(FileStatus fStat)
Should the master delete the file or keep it?
|
boolean |
isStopped() |
void |
setConf(Configuration conf) |
void |
stop(java.lang.String why) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
preClean
public static final java.lang.String HFILE_CACHE_REFRESH_PERIOD_CONF_KEY
public java.lang.Iterable<FileStatus> getDeletableFiles(java.lang.Iterable<FileStatus> files)
FileCleanerDelegate
getDeletableFiles
in interface FileCleanerDelegate
getDeletableFiles
in class BaseFileCleanerDelegate
files
- files to check for deletionpublic void init(java.util.Map<java.lang.String,java.lang.Object> params)
FileCleanerDelegate
init
in interface FileCleanerDelegate
init
in class BaseFileCleanerDelegate
protected boolean isFileDeletable(FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to checkpublic void setConf(Configuration conf)
public void stop(java.lang.String why)
stop
in class BaseHFileCleanerDelegate
public boolean isStopped()
isStopped
in class BaseHFileCleanerDelegate
public SnapshotFileCache getFileCacheForTesting()