Package 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

@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	Description
private final Connection	conn
private static final int	DEFAULT_REPLICATION_BARRIER_CLEANER_INTERVAL
private static final org.slf4j.Logger	LOG
private final ReplicationPeerManager	peerManager
private static final String	REPLICATION_BARRIER_CLEANER_INTERVAL

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

ReplicationBarrierCleaner

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

Method Details

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