@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.