@InterfaceAudience.LimitedPrivate(value="Configuration") public class TimeToLiveProcedureWALCleaner extends BaseLogCleanerDelegate
| Modifier and Type | Field and Description | 
|---|---|
| static long | DEFAULT_TTL | 
| private static org.slf4j.Logger | LOG | 
| private boolean | stopped | 
| private long | ttl | 
| static String | TTL_CONF_KEY | 
| Constructor and Description | 
|---|
| TimeToLiveProcedureWALCleaner() | 
| Modifier and Type | Method and Description | 
|---|---|
| boolean | isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)Should the master delete the file or keep it? | 
| boolean | isStopped() | 
| void | setConf(org.apache.hadoop.conf.Configuration conf) | 
| void | stop(String why)Stop this service. | 
getDeletableFiles, initgetConfclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpreCleanprivate static final org.slf4j.Logger LOG
public static final String TTL_CONF_KEY
public static final long DEFAULT_TTL
private long ttl
private boolean stopped
public TimeToLiveProcedureWALCleaner()
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf in interface org.apache.hadoop.conf.ConfigurablesetConf in class BaseConfigurablepublic boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
BaseFileCleanerDelegateisFileDeletable in class BaseLogCleanerDelegatefStat - file status of the file to checkpublic void stop(String why)
Stoppablewhy - Why we're stopping.public boolean isStopped()
Stoppable.stop(String) has been closed.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.