@InterfaceAudience.LimitedPrivate(value="Configuration") @InterfaceStability.Evolving public class SnapshotHFileCleaner extends BaseHFileCleanerDelegate
Modifier and Type | Field and Description |
---|---|
static 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 |
---|---|
SnapshotFileCache |
getFileCacheForTesting()
Exposed for Testing!
|
boolean |
isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
Should the master delete the file or keep it?
|
boolean |
isStopped() |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
stop(String why)
Stop this service.
|
getDeletableFiles
getConf
public static final String HFILE_CACHE_REFRESH_PERIOD_CONF_KEY
public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to checkpublic void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class BaseConfigurable
public void stop(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()
Copyright © 2014 The Apache Software Foundation. All rights reserved.