@InterfaceAudience.LimitedPrivate(value="Configuration") @InterfaceStability.Evolving 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!
|
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)
Stop this service.
|
getConf
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 deletionprotected boolean isFileDeletable(FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to checkpublic void setConf(Configuration conf)
setConf
in class BaseConfigurable
public void stop(java.lang.String why)
Stoppable
stop
in interface Stoppable
stop
in class BaseHFileCleanerDelegate
why
- Why we're stopping.public boolean isStopped()
isStopped
in interface Stoppable
isStopped
in class BaseHFileCleanerDelegate
Stoppable.stop(String)
has been closed.public SnapshotFileCache getFileCacheForTesting()