Package org.apache.hadoop.hbase.backup.master

Class BackupLogCleaner

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.backup.master.BackupLogCleaner

All Implemented Interfaces:

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

@LimitedPrivate("Configuration")
public class BackupLogCleaner
extends BaseLogCleanerDelegate

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
BackupLogCleaner()

Method Summary

Modifier and Type	Method	Description
protected static boolean	canDeleteFile(Map<Address,Long> addressToBoundaryTs, org.apache.hadoop.fs.Path path)
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
private static boolean	isHMasterWAL(org.apache.hadoop.fs.Path path)
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
private Map<Address,Long>	serverToPreservationBoundaryTs(List<BackupInfo> backups)	Calculates the timestamp boundary up to which all backup roots have already included the WAL.
void	setConf(org.apache.hadoop.conf.Configuration config)
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.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

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

isEmptyDirDeletable, postClean, preClean

Field Details

LOG

private static final org.slf4j.Logger LOG

stopped

private boolean stopped

conn

private Connection conn

Constructor Details

BackupLogCleaner

public BackupLogCleaner()

Method Details

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

serverToPreservationBoundaryTs

private Map<Address,Long> serverToPreservationBoundaryTs(List<BackupInfo> backups)
                                                  throws IOException

Calculates the timestamp boundary up to which all backup roots have already included the WAL. I.e. WALs with a lower (= older) or equal timestamp are no longer needed for future incremental backups.

Throws:

IOException

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

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)

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

Description copied from interface: Stoppable

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

canDeleteFile

protected static boolean canDeleteFile(Map<Address,Long> addressToBoundaryTs,
 org.apache.hadoop.fs.Path path)

isHMasterWAL

private static boolean isHMasterWAL(org.apache.hadoop.fs.Path path)