org.apache.hadoop.hbase.replication.master

Class ReplicationLogCleaner

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

All Implemented Interfaces:

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

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class ReplicationLogCleaner
extends BaseLogCleanerDelegate

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicationLogCleaner.WarnOnlyAbortable

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private long	readZKTimestamp
private ReplicationQueuesClient	replicationQueues
private boolean	stopped
private Set<String>	wals
private ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
ReplicationLogCleaner()

Method Summary

Modifier and Type	Method and 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
boolean	isStopped()
void	preClean() Used to do some initialize work before every period clean
void	setConf(org.apache.hadoop.conf.Configuration config)
void	setConf(org.apache.hadoop.conf.Configuration conf, ZKWatcher zk)
void	setConf(org.apache.hadoop.conf.Configuration conf, ZKWatcher zk, ReplicationQueuesClient replicationQueuesClient)
void	stop(String why) Stop this service.

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

isFileDeletable

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

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

getConf

Field Detail

LOG

private static final org.slf4j.Logger LOG

zkw

private ZKWatcher zkw

replicationQueues

private ReplicationQueuesClient replicationQueues

stopped

private boolean stopped

wals

private Set<String> wals

readZKTimestamp

private long readZKTimestamp

Constructor Detail

ReplicationLogCleaner

public ReplicationLogCleaner()

Method Detail

preClean

public void preClean()

Description copied from interface: FileCleanerDelegate

Used to do some initialize work before every period clean

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

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(org.apache.hadoop.conf.Configuration config)

Specified by:

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

Overrides:

setConf in class BaseConfigurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf,
                    ZKWatcher zk)

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf,
                    ZKWatcher zk,
                    ReplicationQueuesClient replicationQueuesClient)

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

Returns:

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