org.apache.hadoop.hbase.replication.master
Class ReplicationLogCleaner

java.lang.Object
  org.apache.hadoop.hbase.BaseConfigurable
      org.apache.hadoop.hbase.master.cleaner.BaseLogCleanerDelegate
          org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class ReplicationLogCleaner
extends BaseLogCleanerDelegate
implements Abortable

Implementation of a log cleaner that checks if a log is still scheduled for replication before deleting it when its TTL is over.

Constructor Summary

ReplicationLogCleaner()

Method Summary

void	abort(String why, Throwable e)
boolean	isAborted()
boolean	isLogDeletable(org.apache.hadoop.fs.Path filePath) Should the master delete the log or keep it?
boolean	isStopped()
void	setConf(org.apache.hadoop.conf.Configuration config)
void	stop(String why)

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

isFileDeletable

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

getConf

Constructor Detail

ReplicationLogCleaner

public ReplicationLogCleaner()

Method Detail

isLogDeletable

public boolean isLogDeletable(org.apache.hadoop.fs.Path filePath)

Description copied from class: BaseLogCleanerDelegate

Should the master delete the log or keep it?

Implementing classes should override BaseLogCleanerDelegate.isFileDeletable(Path) instead.

Overrides:

isLogDeletable in class BaseLogCleanerDelegate

Parameters:

filePath - full path to log.

Returns:

true if the log is deletable, false (default) 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 why)

Specified by:

stop in interface Stoppable

isStopped

public boolean isStopped()

Specified by:

isStopped in interface Stoppable

abort

public void abort(String why,
                  Throwable e)

Specified by:

abort in interface Abortable

isAborted

public boolean isAborted()

Specified by:

isAborted in interface Abortable