org.apache.hadoop.hbase.master.cleaner

Class BaseTimeToLiveFileCleaner

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

All Implemented Interfaces:

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

Direct Known Subclasses:

TimeToLiveHFileCleaner, TimeToLiveLogCleaner, TimeToLiveMasterLocalStoreHFileCleaner, TimeToLiveMasterLocalStoreWALCleaner, TimeToLiveProcedureWALCleaner

@InterfaceAudience.Private
public abstract class BaseTimeToLiveFileCleaner
extends BaseLogCleanerDelegate

Base class for time to live file cleaner.

Field Summary

Fields

Modifier and Type	Field and Description
private static DateTimeFormatter	FORMATTER
private static org.slf4j.Logger	LOG
private boolean	stopped
private long	ttlMs

Constructor Summary

Constructors

Constructor and Description
BaseTimeToLiveFileCleaner()

Method Summary

Modifier and Type	Method and Description
protected abstract long	getTtlMs(org.apache.hadoop.conf.Configuration conf)
boolean	isFileDeletable(org.apache.hadoop.fs.FileStatus status) Should the master delete the file or keep it?
boolean	isStopped() Returns True if Stoppable.stop(String) has been closed.
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	stop(String why) Stop this service.
protected abstract boolean	valiateFilename(org.apache.hadoop.fs.Path file)

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

isEmptyDirDeletable, preClean

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

getConf

Field Detail

LOG

private static final org.slf4j.Logger LOG

FORMATTER

private static final DateTimeFormatter FORMATTER

ttlMs

private long ttlMs

stopped

private volatile boolean stopped

Constructor Detail

BaseTimeToLiveFileCleaner

public BaseTimeToLiveFileCleaner()

Method Detail

setConf

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

Specified by:

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

Overrides:

setConf in class BaseConfigurable

isFileDeletable

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

Description copied from class: BaseFileCleanerDelegate

Should the master delete the file or keep it?

Overrides:

isFileDeletable in class BaseLogCleanerDelegate

Parameters:

status - file status of the file to check

Returns:

true if the file is deletable, false if not

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()

Description copied from interface: Stoppable

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

getTtlMs

protected abstract long getTtlMs(org.apache.hadoop.conf.Configuration conf)

valiateFilename

protected abstract boolean valiateFilename(org.apache.hadoop.fs.Path file)