org.apache.hadoop.hbase.master.cleaner

Class ReplicationBarrierCleaner

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.master.cleaner.ReplicationBarrierCleaner

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class ReplicationBarrierCleaner
extends ScheduledChore

Used to clean the useless barriers in HConstants.REPLICATION_BARRIER_FAMILY_STR family in meta table.

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	conn
private static int	DEFAULT_REPLICATION_BARRIER_CLEANER_INTERVAL
private static org.slf4j.Logger	LOG
private ReplicationPeerManager	peerManager
private static String	REPLICATION_BARRIER_CLEANER_INTERVAL

Constructor Summary

Constructors

Constructor and Description
ReplicationBarrierCleaner(org.apache.hadoop.conf.Configuration conf, Stoppable stopper, Connection conn, ReplicationPeerManager peerManager)

Method Summary

Modifier and Type	Method and Description
void	chore() The task to execute on each scheduled execution of the Chore

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

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

REPLICATION_BARRIER_CLEANER_INTERVAL

private static final String REPLICATION_BARRIER_CLEANER_INTERVAL

See Also:

Constant Field Values

DEFAULT_REPLICATION_BARRIER_CLEANER_INTERVAL

private static final int DEFAULT_REPLICATION_BARRIER_CLEANER_INTERVAL

See Also:

Constant Field Values

conn

private final Connection conn

peerManager

private final ReplicationPeerManager peerManager

Constructor Detail

ReplicationBarrierCleaner

public ReplicationBarrierCleaner(org.apache.hadoop.conf.Configuration conf,
                                 Stoppable stopper,
                                 Connection conn,
                                 ReplicationPeerManager peerManager)

Method Detail

chore

public void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore