@InterfaceAudience.LimitedPrivate(value="Configuration") public class LongTermArchivingHFileCleaner extends BaseHFileCleanerDelegate
BaseHFileCleanerDelegate
that only cleans HFiles that don't belong to a table that is
currently being archived.
This only works properly if the
TimeToLiveHFileCleaner
is also enabled
(it always should be), since it may take a little time for the ZK notification to
propagate, in which case we may accidentally delete some files.
Constructor and Description |
---|
LongTermArchivingHFileCleaner() |
Modifier and Type | Method and Description |
---|---|
boolean |
isFileDeletable(FileStatus fStat)
Should the master delete the file or keep it?
|
void |
setConf(Configuration config) |
void |
stop(java.lang.String reason)
Stop this service.
|
isStopped
getDeletableFiles
getConf
public boolean isFileDeletable(FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to checkpublic void setConf(Configuration config)
setConf
in class BaseConfigurable
public void stop(java.lang.String reason)
Stoppable
stop
in interface Stoppable
stop
in class BaseHFileCleanerDelegate
reason
- Why we're stopping.