org.apache.hadoop.hbase.backup.example

Class LongTermArchivingHFileCleaner

java.lang.Object

org.apache.hadoop.hbase.BaseConfigurable

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

org.apache.hadoop.hbase.master.cleaner.BaseHFileCleanerDelegate

org.apache.hadoop.hbase.backup.example.LongTermArchivingHFileCleaner

All Implemented Interfaces:

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

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class LongTermArchivingHFileCleaner
extends BaseHFileCleanerDelegate

BaseHFileCleanerDelegate that only cleans HFiles that don't belong to a table that is currently being archived.

This only works properly if the TimeToLiveHFileCleaner is also enabled (it always should be), since it may take a little time for the ZK notification to propagate, in which case we may accidentally delete some files.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) TableHFileArchiveTracker	archiveTracker
private org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LongTermArchivingHFileCleaner()

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?
void	setConf(org.apache.hadoop.conf.Configuration config)
void	stop(String reason) Stop this service.

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

isStopped

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

archiveTracker

TableHFileArchiveTracker archiveTracker

fs

private org.apache.hadoop.fs.FileSystem fs

Constructor Detail

LongTermArchivingHFileCleaner

public LongTermArchivingHFileCleaner()

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?

Specified by:

isFileDeletable in class BaseFileCleanerDelegate

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

Specified by:

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

Overrides:

setConf in class BaseConfigurable

stop

public void stop(String reason)

Description copied from interface: Stoppable

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

Specified by:

stop in interface Stoppable

Overrides:

stop in class BaseHFileCleanerDelegate

Parameters:

reason - Why we're stopping.