public class ReplicationLogCleaner extends BaseLogCleanerDelegate
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationLogCleaner.WarnOnlyAbortable |
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 |
preClean()
Used to do some initialize work before every period clean
|
void |
setConf(Configuration config) |
void |
setConf(Configuration conf,
ZKWatcher zk) |
void |
setConf(Configuration conf,
ZKWatcher zk,
ReplicationQueuesClient replicationQueuesClient) |
void |
stop(java.lang.String why) |
isFileDeletable
init
public void preClean()
FileCleanerDelegate
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 setConf(Configuration conf, ZKWatcher zk, ReplicationQueuesClient replicationQueuesClient)
public void stop(java.lang.String why)
public boolean isStopped()