Package org.apache.hadoop.hbase.replication.regionserver

Class ReplicationMarkerChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.replication.regionserver.ReplicationMarkerChore

All Implemented Interfaces:

Runnable

@Private
public class ReplicationMarkerChore
extends ScheduledChore

This chore is responsible to create replication marker rows with special WALEdit with family as WALEdit.METAFAMILY and column qualifier as WALEdit.REPLICATION_MARKER and empty value. If config key REPLICATION_MARKER_ENABLED_KEY is set to true, then we will create 1 marker row every REPLICATION_MARKER_CHORE_DURATION_KEY ms ReplicationSourceWALReader will populate the Replication Marker edit with region_server_name, wal_name and wal_offset encoded in WALProtos.ReplicationMarkerDescriptor object. Replication will change the REPLICATION_SCOPE for this edit to GLOBAL so that it can replicate. On the sink cluster, ReplicationSink will convert the ReplicationMarkerDescriptor into a Put mutation to REPLICATION_SINK_TRACKER_TABLE_NAME_STR table.

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	DELIMITER
private static final org.slf4j.Logger	LOG
private static final MultiVersionConcurrencyControl	MVCC
static final RegionInfo	REGION_INFO
static final int	REPLICATION_MARKER_CHORE_DURATION_DEFAULT
static final String	REPLICATION_MARKER_CHORE_DURATION_KEY
static final boolean	REPLICATION_MARKER_ENABLED_DEFAULT
static final String	REPLICATION_MARKER_ENABLED_KEY
private final RegionServerServices	rsServices
private WAL	wal

Constructor Summary

Constructors

Constructor	Description
ReplicationMarkerChore(Stoppable stopper, RegionServerServices rsServices, int period)

Method Summary

Modifier and Type	Method	Description
protected void	chore()	The task to execute on each scheduled execution of the Chore
static byte[]	getRowKey(String serverName, long timestamp)	Creates a rowkey with region server name and timestamp.

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

MVCC

private static final MultiVersionConcurrencyControl MVCC

REGION_INFO

public static final RegionInfo REGION_INFO

DELIMITER

private static final String DELIMITER

See Also:

• Constant Field Values

rsServices

private final RegionServerServices rsServices

wal

private WAL wal

REPLICATION_MARKER_ENABLED_KEY

public static final String REPLICATION_MARKER_ENABLED_KEY

See Also:

• Constant Field Values

REPLICATION_MARKER_ENABLED_DEFAULT

public static final boolean REPLICATION_MARKER_ENABLED_DEFAULT

See Also:

• Constant Field Values

REPLICATION_MARKER_CHORE_DURATION_KEY

public static final String REPLICATION_MARKER_CHORE_DURATION_KEY

See Also:

• Constant Field Values

REPLICATION_MARKER_CHORE_DURATION_DEFAULT

public static final int REPLICATION_MARKER_CHORE_DURATION_DEFAULT

See Also:

• Constant Field Values

Constructor Details

ReplicationMarkerChore

public ReplicationMarkerChore(Stoppable stopper,
 RegionServerServices rsServices,
 int period)

Method Details

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

getRowKey

public static byte[] getRowKey(String serverName,
 long timestamp)

Creates a rowkey with region server name and timestamp.

Parameters:

serverName - region server name

timestamp - timestamp