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

Class ReplicationSourceWALActionListener

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALActionListener

All Implemented Interfaces:

WALActionsListener

@Private
class ReplicationSourceWALActionListener
extends Object
implements WALActionsListener

Used to receive new wals.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.wal.WALActionsListener

WALActionsListener.RollRequestReason

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.conf.Configuration	conf
private final ReplicationSourceManager	manager

Constructor Summary

Constructors

Constructor	Description
ReplicationSourceWALActionListener(org.apache.hadoop.conf.Configuration conf, ReplicationSourceManager manager)

Method Summary

Modifier and Type	Method	Description
void	postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath)	The WAL has been rolled.
(package private) static void	scopeWALEdits(WALKey logKey, WALEdit logEdit, org.apache.hadoop.conf.Configuration conf)	Utility method used to set the correct scopes on each log key.
void	visitLogEntryBeforeWrite(RegionInfo info, WALKey logKey, WALEdit logEdit)	Called before each write.

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.hbase.regionserver.wal.WALActionsListener

logCloseRequested, logRollRequested, postAppend, postLogArchive, postSync, preLogArchive, preLogRoll

Field Details

conf

private final org.apache.hadoop.conf.Configuration conf

manager

private final ReplicationSourceManager manager

Constructor Details

ReplicationSourceWALActionListener

public ReplicationSourceWALActionListener(org.apache.hadoop.conf.Configuration conf,
 ReplicationSourceManager manager)

Method Details

postLogRoll

public void postLogRoll(org.apache.hadoop.fs.Path oldPath,
 org.apache.hadoop.fs.Path newPath)
                 throws IOException

Description copied from interface: WALActionsListener

The WAL has been rolled. The oldPath can be null if this is the first log file from the regionserver.

Specified by:

postLogRoll in interface WALActionsListener

Parameters:

oldPath - the path to the old wal

newPath - the path to the new wal

Throws:

IOException

visitLogEntryBeforeWrite

public void visitLogEntryBeforeWrite(RegionInfo info,
 WALKey logKey,
 WALEdit logEdit)

Description copied from interface: WALActionsListener

Called before each write.

Specified by:

visitLogEntryBeforeWrite in interface WALActionsListener

scopeWALEdits

static void scopeWALEdits(WALKey logKey,
 WALEdit logEdit,
 org.apache.hadoop.conf.Configuration conf)

Utility method used to set the correct scopes on each log key. Doesn't set a scope on keys from compaction WAL edits and if the scope is local.

Parameters:

logKey - Key that may get scoped according to its edits

logEdit - Edits used to lookup the scopes