org.apache.hadoop.hbase.replication.regionserver

Class ReplicationSourceWALActionListener

java.lang.Object

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

All Implemented Interfaces:

WALActionsListener

@InterfaceAudience.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 and Description
private org.apache.hadoop.conf.Configuration	conf
private ReplicationSourceManager	manager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL has been rolled.
void	preLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL is going to be 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(WALKey logKey, WALEdit logEdit)

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, visitLogEntryBeforeWrite

Field Detail

conf

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

manager

private final ReplicationSourceManager manager

Constructor Detail

ReplicationSourceWALActionListener

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

Method Detail

preLogRoll

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

Description copied from interface: WALActionsListener

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

Specified by:

preLogRoll in interface WALActionsListener

Parameters:

oldPath - the path to the old wal

newPath - the path to the new wal

Throws:

IOException

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(WALKey logKey,
                                     WALEdit logEdit)
                              throws IOException

Specified by:

visitLogEntryBeforeWrite in interface WALActionsListener

logEdit - TODO: Retire this in favor of WALActionsListener.visitLogEntryBeforeWrite(RegionInfo, WALKey, WALEdit) It only exists to get scope when replicating. Scope should be in the WALKey and not need us passing in a htd.

Throws:

IOException - If failed to parse the WALEdit

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