@InterfaceAudience.LimitedPrivate(value="Configuration") 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 |
---|---|
Iterable<org.apache.hadoop.fs.FileStatus> |
getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
Determines which of the given files are safe to delete
|
boolean |
isStopped() |
void |
setConf(org.apache.hadoop.conf.Configuration config) |
void |
setConf(org.apache.hadoop.conf.Configuration conf,
ZooKeeperWatcher zk) |
void |
setConf(org.apache.hadoop.conf.Configuration conf,
ZooKeeperWatcher zk,
ReplicationQueuesClient replicationQueuesClient) |
void |
stop(String why)
Stop this service.
|
isFileDeletable, isLogDeletable
init
getConf
public Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
FileCleanerDelegate
getDeletableFiles
in interface FileCleanerDelegate
getDeletableFiles
in class BaseFileCleanerDelegate
files
- files to check for deletionpublic void setConf(org.apache.hadoop.conf.Configuration config)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class BaseConfigurable
public void setConf(org.apache.hadoop.conf.Configuration conf, ZooKeeperWatcher zk)
public void setConf(org.apache.hadoop.conf.Configuration conf, ZooKeeperWatcher zk, ReplicationQueuesClient replicationQueuesClient)
public void stop(String why)
Stoppable
why
- Why we're stopping.public boolean isStopped()
Stoppable.stop(String)
has been closed.Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.