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

Class StandbyCheckpointer

java.lang.Object

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

@InterfaceAudience.Private
public class StandbyCheckpointer
extends Object

Thread which runs inside the NN when it's in Standby state, periodically waking up to take a checkpoint of the namespace. When it takes a checkpoint, it saves it to its local storage and then uploads it to the remote NameNode.

Constructor Summary

Constructors

Constructor and Description
StandbyCheckpointer(Configuration conf, FSNamesystem ns)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelAndPreventCheckpoints(String msg) Cancel any checkpoint that's currently being made, and prevent any new checkpoints from starting for the next minute or so.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StandbyCheckpointer

public StandbyCheckpointer(Configuration conf,
                   FSNamesystem ns)
                    throws IOException

Throws:

IOException

Method Detail

start

public void start()

stop

public void stop()
          throws IOException

Throws:

IOException

cancelAndPreventCheckpoints

public void cancelAndPreventCheckpoints(String msg)
                                 throws ServiceFailedException

Cancel any checkpoint that's currently being made, and prevent any new checkpoints from starting for the next minute or so.

Throws:

ServiceFailedException