@InterfaceAudience.Private public class WALEventTrackerListener extends Object implements WALActionsListener
Modifier and Type | Class and Description |
---|---|
static class |
WALEventTrackerListener.WalState |
WALActionsListener.RollRequestReason
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
private NamedQueueRecorder |
namedQueueRecorder |
private String |
serverName |
Constructor and Description |
---|
WALEventTrackerListener(org.apache.hadoop.conf.Configuration conf,
NamedQueueRecorder namedQueueRecorder,
ServerName serverName) |
Modifier and Type | Method and Description |
---|---|
private WALEventTrackerPayload |
getPayload(String path,
String state,
long walLength) |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
logCloseRequested, logRollRequested, postAppend, postLogArchive, postSync, preLogArchive, visitLogEntryBeforeWrite
private final org.apache.hadoop.conf.Configuration conf
private final NamedQueueRecorder namedQueueRecorder
private final String serverName
public WALEventTrackerListener(org.apache.hadoop.conf.Configuration conf, NamedQueueRecorder namedQueueRecorder, ServerName serverName)
public void preLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath)
WALActionsListener
preLogRoll
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walpublic void postLogRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath)
WALActionsListener
postLogRoll
in interface WALActionsListener
oldPath
- the path to the old walnewPath
- the path to the new walprivate WALEventTrackerPayload getPayload(String path, String state, long walLength)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.