public class ReplicationHFileCleaner extends BaseHFileCleanerDelegate
Constructor and Description |
---|
ReplicationHFileCleaner() |
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
|
boolean |
isFileDeletable(FileStatus fStat)
Should the master delete the file or keep it?
|
boolean |
isStopped() |
void |
setConf(Configuration config) |
void |
setConf(Configuration conf,
ZKWatcher zk) |
void |
stop(java.lang.String why) |
init
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
preClean
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 deletionpublic void setConf(Configuration config)
public void setConf(Configuration conf, ZKWatcher zk)
public void stop(java.lang.String why)
stop
in class BaseHFileCleanerDelegate
public boolean isStopped()
isStopped
in class BaseHFileCleanerDelegate
public boolean isFileDeletable(FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseFileCleanerDelegate
fStat
- file status of the file to check