public static class WALActionsListener.Base extends Object implements WALActionsListener
WALActionsListener.Base
Constructor and Description |
---|
WALActionsListener.Base() |
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,
WALKey logKey,
WALEdit logEdit)
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) |
public void preLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
WALActionsListener
preLogRoll
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walIOException
public void postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
WALActionsListener
postLogRoll
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walIOException
public void preLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
WALActionsListener
preLogArchive
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walIOException
public void postLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
WALActionsListener
postLogArchive
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walIOException
public void logRollRequested(boolean tooFewReplicas)
WALActionsListener
logRollRequested
in interface WALActionsListener
public void logCloseRequested()
WALActionsListener
logCloseRequested
in interface WALActionsListener
public void visitLogEntryBeforeWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit)
WALActionsListener
visitLogEntryBeforeWrite
in interface WALActionsListener
public void visitLogEntryBeforeWrite(HTableDescriptor htd, WALKey logKey, WALEdit logEdit) throws IOException
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
.IOException
- If failed to parse the WALEditpublic void postAppend(long entryLen, long elapsedTimeMillis, WALKey logKey, WALEdit logEdit) throws IOException
WALActionsListener
postAppend
in interface WALActionsListener
entryLen
- approx length of cells in this append.elapsedTimeMillis
- elapsed time in milliseconds.logKey
- A WAL keylogEdit
- A WAL edit containing list of cells.IOException
- if any network or I/O occurredpublic void postSync(long timeInNanos, int handlerSyncs)
WALActionsListener
postSync
in interface WALActionsListener
timeInNanos
- How long the filesystem sync took in nanoseconds.handlerSyncs
- How many sync handler calls were released by this call to filesystem
sync.Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.