@InterfaceAudience.LimitedPrivate(value="Configuration") public class ReplicationLogCleaner extends BaseLogCleanerDelegate
Constructor and Description |
---|
ReplicationLogCleaner() |
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 |
isStopped() |
void |
setConf(Configuration config) |
void |
setConf(Configuration conf,
ZooKeeperWatcher zk) |
void |
stop(java.lang.String why)
Stop this service.
|
isFileDeletable, isLogDeletable
getConf
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)
setConf
in class BaseConfigurable
public void setConf(Configuration conf, ZooKeeperWatcher zk)
public void stop(java.lang.String why)
Stoppable
why
- Why we're stopping.public boolean isStopped()
Stoppable.stop(String)
has been closed.