org.apache.hadoop.hbase.master.cleaner

Class TimeToLiveLogCleaner

java.lang.Object

org.apache.hadoop.hbase.BaseConfigurable

org.apache.hadoop.hbase.master.cleaner.BaseFileCleanerDelegate

org.apache.hadoop.hbase.master.cleaner.BaseLogCleanerDelegate

org.apache.hadoop.hbase.master.cleaner.TimeToLiveLogCleaner

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, FileCleanerDelegate, Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class TimeToLiveLogCleaner
extends BaseLogCleanerDelegate

Log cleaner that uses the timestamp of the wal to determine if it should be deleted. By default they are allowed to live for 10 minutes.

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
TimeToLiveLogCleaner()

Method Summary

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.

Methods inherited from class org.apache.hadoop.hbase.master.cleaner.BaseFileCleanerDelegate

getDeletableFiles, init

Methods inherited from class org.apache.hadoop.hbase.BaseConfigurable

getConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.master.cleaner.FileCleanerDelegate

preClean

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf

Field Detail

LOG

private static final org.slf4j.Logger LOG

TTL_CONF_KEY

public static final String TTL_CONF_KEY

See Also:

Constant Field Values

DEFAULT_TTL

public static final long DEFAULT_TTL

See Also:

Constant Field Values

ttl

private long ttl

stopped

private boolean stopped

Constructor Detail

TimeToLiveLogCleaner

public TimeToLiveLogCleaner()

Method Detail

isFileDeletable

public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)

Description copied from class: BaseFileCleanerDelegate

Should the master delete the file or keep it?

Overrides:

isFileDeletable in class BaseLogCleanerDelegate

Parameters:

fStat - file status of the file to check

Returns:

true if the file is deletable, false if not

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

Overrides:

setConf in class BaseConfigurable

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Returns:

True if Stoppable.stop(String) has been closed.