@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, isLogDeletableinitgetConfpublic Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)
FileCleanerDelegategetDeletableFiles in interface FileCleanerDelegategetDeletableFiles in class BaseFileCleanerDelegatefiles - files to check for deletionpublic void setConf(org.apache.hadoop.conf.Configuration config)
setConf in interface org.apache.hadoop.conf.ConfigurablesetConf in class BaseConfigurablepublic 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)
Stoppablewhy - Why we're stopping.public boolean isStopped()
Stoppable.stop(String) has been closed.Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.