Package org.apache.hadoop.hbase.replication.master

Class ReplicationHFileCleaner

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.replication.master.ReplicationHFileCleaner

All Implemented Interfaces:

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

@LimitedPrivate("Configuration")
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.

Field Summary

Fields

Modifier and Type	Field	Description
private Connection	conn
private static final org.slf4j.Logger	LOG
private ReplicationQueueStorage	rqs
private boolean	shareConn
private boolean	stopped

Constructor Summary

Constructors

Constructor	Description
ReplicationHFileCleaner()

Method Summary

Modifier and Type	Method	Description
Iterable<org.apache.hadoop.fs.FileStatus>	getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)	Determines which of the given files are safe to delete
void	init(Map<String,Object> params)	this method is used to pass some instance into subclass
boolean	isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)	Should the master delete the file or keep it?
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
void	stop(String why)	Stop this service.

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

getConf, setConf

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.conf.Configurable

getConf, setConf

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

isEmptyDirDeletable, postClean, preClean

Field Details

LOG

private static final org.slf4j.Logger LOG

conn

private Connection conn

shareConn

private boolean shareConn

rqs

private ReplicationQueueStorage rqs

stopped

private boolean stopped

Constructor Details

ReplicationHFileCleaner

public ReplicationHFileCleaner()

Method Details

getDeletableFiles

public Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)

Description copied from interface: FileCleanerDelegate

Determines which of the given files are safe to delete

This method can be called concurrently by multiple threads. Implementations must be thread safe.

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

init

public void init(Map<String,Object> params)

Description copied from interface: FileCleanerDelegate

this method is used to pass some instance into subclass

Specified by:

init in interface FileCleanerDelegate

Overrides:

init in class BaseFileCleanerDelegate

stop

public void stop(String why)

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:

why - Why we're stopping.

isStopped

public boolean isStopped()

Description copied from interface: Stoppable

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

Specified by:

isStopped in interface Stoppable

Overrides:

isStopped in class BaseHFileCleanerDelegate

isFileDeletable

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

Description copied from class: BaseFileCleanerDelegate

Should the master delete the file or keep it?

This method can be called concurrently by multiple threads. Implementations must be thread safe.

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