org.apache.hadoop.hbase.master.snapshot

Class SnapshotLogCleaner

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.master.snapshot.SnapshotLogCleaner

All Implemented Interfaces:

FileCleanerDelegate, Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
 @InterfaceStability.Evolving
public class SnapshotLogCleaner
extends BaseLogCleanerDelegate

Implementation of a log cleaner that checks if a log is still used by snapshots of HBase tables.

Constructor Summary

Constructors

Constructor and Description
SnapshotLogCleaner()

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	isStopped()
void	setConf(Configuration conf) This method should only be called once, as it starts a thread to keep the cache up-to-date.
void	stop(java.lang.String why) Stop this service.

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

isFileDeletable, isLogDeletable

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

Constructor Detail

SnapshotLogCleaner

public SnapshotLogCleaner()

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

This method should only be called once, as it starts a thread to keep the cache up-to-date.

Overrides:

setConf in class BaseConfigurable

stop

public void stop(java.lang.String why)

Description copied from interface: Stoppable

Stop this service.

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Returns:

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