@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.
|
getDeletableFilesgetConfpublic static final String HFILE_CACHE_REFRESH_PERIOD_CONF_KEY
public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
BaseFileCleanerDelegateisFileDeletable in class BaseFileCleanerDelegatefStat - file status of the file to checkpublic void setConf(org.apache.hadoop.conf.Configuration conf)
setConf in interface org.apache.hadoop.conf.ConfigurablesetConf in class BaseConfigurablepublic void stop(String why)
Stoppablestop in interface Stoppablestop in class BaseHFileCleanerDelegatewhy - Why we're stopping.public boolean isStopped()
isStopped in interface StoppableisStopped in class BaseHFileCleanerDelegateStoppable.stop(String) has been closed.public SnapshotFileCache getFileCacheForTesting()
Copyright © 2014 The Apache Software Foundation. All rights reserved.