ReplicationLogCleaner (Apache HBase 1.2.12 API)

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

Nested Classes
Modifier and Type	Class and Description
`static class`	`ReplicationLogCleaner.WarnOnlyAbortable`

Field Summary

Fields
Modifier and Type	Field and Description
`private static org.apache.commons.logging.Log`	`LOG`
`private ReplicationQueuesClient`	`replicationQueues`
`private boolean`	`stopped`
`private ZooKeeperWatcher`	`zkw`

Constructor Summary

Constructors
Constructor and Description

ReplicationLogCleaner()

Constructors
Constructor and Description
`ReplicationLogCleaner()`

Method Summary

Methods
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()`
`private Set<String>`	`loadWALsFromQueues()` Load all wals in all replication queues from ZK.
`void`	`setConf(org.apache.hadoop.conf.Configuration config)`
`void`	`setConf(org.apache.hadoop.conf.Configuration conf, ZooKeeperWatcher zk)`
`void`	`setConf(org.apache.hadoop.conf.Configuration conf, ZooKeeperWatcher zk, ReplicationQueuesClient replicationQueuesClient)`
`void`	`stop(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.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.apache.commons.logging.Log LOG
```
  - zkw
```
private ZooKeeperWatcher zkw
```
  - replicationQueues
```
private ReplicationQueuesClient replicationQueues
```
  - stopped
```
private boolean stopped
```
- Constructor Detail
  - ReplicationLogCleaner
```
public ReplicationLogCleaner()
```
- Method Detail
  - 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
  - loadWALsFromQueues
```
private Set<String> loadWALsFromQueues()
                                throws org.apache.zookeeper.KeeperException
```
    Load all wals in all replication queues from ZK. This method guarantees to return a snapshot which contains all WALs in the zookeeper at the start of this call even there is concurrent queue failover. However, some newly created WALs during the call may not be included.
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - 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,
           ZooKeeperWatcher zk)
```
  - setConf
```
public void setConf(org.apache.hadoop.conf.Configuration conf,
           ZooKeeperWatcher zk,
           ReplicationQueuesClient replicationQueuesClient)
```
  - stop
```
public void stop(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.

Class ReplicationLogCleaner

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

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

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

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

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.hadoop.conf.Configurable

Field Detail

LOG

zkw

replicationQueues

stopped

Constructor Detail

ReplicationLogCleaner

Method Detail

getDeletableFiles

loadWALsFromQueues

setConf

setConf

setConf

stop

isStopped