org.apache.hadoop.hbase.replication.master

Class ReplicationHFileCleaner

java.lang.Object

BaseConfigurable

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

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

org.apache.hadoop.hbase.replication.master.ReplicationHFileCleaner

All Implemented Interfaces:

FileCleanerDelegate

public class ReplicationHFileCleaner
extends BaseHFileCleanerDelegate

Implementation of a file cleaner that checks if a hfile is still scheduled for replication before deleting it from hfile archive directory.

Constructor Summary

Constructors

Constructor and Description
ReplicationHFileCleaner()

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<FileStatus>	getDeletableFiles(java.lang.Iterable<FileStatus> files) Determines which of the given files are safe to delete
boolean	isFileDeletable(FileStatus fStat) Should the master delete the file or keep it?
boolean	isStopped()
void	setConf(Configuration config)
void	setConf(Configuration conf, ZKWatcher zk)
void	stop(java.lang.String why)

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

init

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

Constructor Detail

ReplicationHFileCleaner

public ReplicationHFileCleaner()

Method Detail

getDeletableFiles

public java.lang.Iterable<FileStatus> getDeletableFiles(java.lang.Iterable<FileStatus> files)

Description copied from interface: FileCleanerDelegate

Determines which of the given files are safe to delete

Specified by:

getDeletableFiles in interface FileCleanerDelegate

Overrides:

getDeletableFiles in class BaseFileCleanerDelegate

Parameters:

files - files to check for deletion

Returns:

files that are ok to delete according to this cleaner

setConf

public void setConf(Configuration config)

setConf

public void setConf(Configuration conf,
                    ZKWatcher zk)

stop

public void stop(java.lang.String why)

Overrides:

stop in class BaseHFileCleanerDelegate

isStopped

public boolean isStopped()

Overrides:

isStopped in class BaseHFileCleanerDelegate

isFileDeletable

public boolean isFileDeletable(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