@InterfaceAudience.Private public interface WALActionsListener
Modifier and Type | Interface and Description |
---|---|
static class |
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) |
void preLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path to the old walnewPath
- the path to the new walIOException
void postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path to the old walnewPath
- the path to the new walIOException
void preLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path to the old walnewPath
- the path to the new walIOException
void postLogArchive(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path to the old walnewPath
- the path to the new walIOException
void logRollRequested(boolean tooFewReplicas)
void logCloseRequested()
void visitLogEntryBeforeWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit)
info
- logKey
- logEdit
- void visitLogEntryBeforeWrite(HTableDescriptor htd, WALKey logKey, WALEdit logEdit) throws IOException
htd
- logKey
- logEdit
- TODO: Retire this in favor of
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 WALEditvoid postAppend(long entryLen, long elapsedTimeMillis, WALKey logKey, WALEdit logEdit) throws IOException
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 occurredvoid postSync(long timeInNanos, int handlerSyncs)
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.