org.apache.hadoop.hdfs.server.namenode.ha

Class EditLogTailer

java.lang.Object

org.apache.hadoop.hdfs.server.namenode.ha.EditLogTailer

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class EditLogTailer
extends Object

EditLogTailer represents a thread which periodically reads from edits journals and applies the transactions contained within to a given FSNamesystem.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
EditLogTailer(FSNamesystem namesystem, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	catchupDuringFailover()
long	getLastLoadTimestamp()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

EditLogTailer

public EditLogTailer(FSNamesystem namesystem,
             Configuration conf)

Method Detail

start

public void start()

stop

public void stop()
          throws IOException

Throws:

IOException

catchupDuringFailover

public void catchupDuringFailover()
                           throws IOException

Throws:

IOException

getLastLoadTimestamp

public long getLastLoadTimestamp()

Returns:

timestamp (in msec) of when we last loaded a non-zero number of edits.