org.apache.hadoop.hbase.regionserver.wal

Class WALActionsListener.Base

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.WALActionsListener.Base

All Implemented Interfaces:

WALActionsListener

Direct Known Subclasses:

MetricsWAL, Replication

Enclosing interface:

WALActionsListener

public static class WALActionsListener.Base
extends Object
implements WALActionsListener

Nested Class Summary

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

WALActionsListener.Base

Constructor Summary

Constructors

Constructor and Description
WALActionsListener.Base()

Method Summary

Methods

Modifier and Type	Method and Description
void	logCloseRequested() The WAL is about to close.
void	logRollRequested(boolean tooFewReplicas) A request was made that the WAL be rolled.
void	postAppend(long entryLen, long elapsedTimeMillis) For notification post append to the writer.
void	postLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL has been archived.
void	postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL has been rolled.
void	postSync(long timeInNanos, int handlerSyncs) For notification post writer sync.
void	preLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL is going to be archived.
void	preLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) The WAL is going to be rolled.
void	visitLogEntryBeforeWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit) Called before each write.
void	visitLogEntryBeforeWrite(HTableDescriptor htd, WALKey logKey, WALEdit logEdit)

Methods inherited from class java.lang.Object

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

Constructor Detail

WALActionsListener.Base

public WALActionsListener.Base()

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

preLogArchive

public void preLogArchive(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 archived.

Specified by:

preLogArchive in interface WALActionsListener

Parameters:

oldPath - the path to the old wal

newPath - the path to the new wal

Throws:

IOException

postLogArchive

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

Description copied from interface: WALActionsListener

The WAL has been archived.

Specified by:

postLogArchive in interface WALActionsListener

Parameters:

oldPath - the path to the old wal

newPath - the path to the new wal

Throws:

IOException

logRollRequested

public void logRollRequested(boolean tooFewReplicas)

Description copied from interface: WALActionsListener

A request was made that the WAL be rolled.

Specified by:

logRollRequested in interface WALActionsListener

logCloseRequested

public void logCloseRequested()

Description copied from interface: WALActionsListener

The WAL is about to close.

Specified by:

logCloseRequested in interface WALActionsListener

visitLogEntryBeforeWrite

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

Description copied from interface: WALActionsListener

Called before each write.

Specified by:

visitLogEntryBeforeWrite in interface WALActionsListener

visitLogEntryBeforeWrite

public void visitLogEntryBeforeWrite(HTableDescriptor htd,
                            WALKey logKey,
                            WALEdit logEdit)

Specified by:

visitLogEntryBeforeWrite in interface WALActionsListener

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

postAppend

public void postAppend(long entryLen,
              long elapsedTimeMillis)

Description copied from interface: WALActionsListener

For notification post append to the writer. Used by metrics system at least. TODO: Combine this with above.

Specified by:

postAppend in interface WALActionsListener

Parameters:

entryLen - approx length of cells in this append.

elapsedTimeMillis - elapsed time in milliseconds.

postSync

public void postSync(long timeInNanos,
            int handlerSyncs)

Description copied from interface: WALActionsListener

For notification post writer sync. Used by metrics system at least.

Specified by:

postSync in interface WALActionsListener

Parameters:

timeInNanos - How long the filesystem sync took in nanoseconds.

handlerSyncs - How many sync handler calls were released by this call to filesystem sync.