@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, init
getConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
preClean
private 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.Configurable
setConf
in class BaseConfigurable
public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)
BaseFileCleanerDelegate
isFileDeletable
in class BaseLogCleanerDelegate
fStat
- file status of the file to checkpublic void stop(String why)
Stoppable
why
- Why we're stopping.public boolean isStopped()
Stoppable.stop(String)
has been closed.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.