@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.
Modifier and Type | Field and Description |
---|---|
(package private) TableHFileArchiveTracker |
archiveTracker |
private org.apache.hadoop.fs.FileSystem |
fs |
private static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
LongTermArchivingHFileCleaner() |
Modifier and Type | Method and Description |
---|---|
boolean |
isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
Should the master delete the file or keep it?
|
void |
setConf(org.apache.hadoop.conf.Configuration config) |
void |
stop(String reason)
Stop this service.
|
isStopped
getDeletableFiles, init
getConf
private static final org.apache.commons.logging.Log LOG
TableHFileArchiveTracker archiveTracker
private org.apache.hadoop.fs.FileSystem fs
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 config)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class BaseConfigurable
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.