org.apache.hadoop.hdfs.qjournal.server

Class JournalNode

java.lang.Object

org.apache.hadoop.hdfs.qjournal.server.JournalNode

All Implemented Interfaces:

Configurable, JournalNodeMXBean, Tool

@InterfaceAudience.Private
public class JournalNode
extends Object
implements Tool, Configurable, JournalNodeMXBean

The JournalNode is a daemon which allows namenodes using the QuorumJournalManager to log and retrieve edits stored remotely. It is a thin wrapper around a local edit log directory with the addition of facilities to participate in the quorum protocol.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
JournalNode()

Method Summary

Methods

Modifier and Type	Method and Description
InetSocketAddress	getBoundHttpAddress()
InetSocketAddress	getBoundIpcAddress()
Configuration	getConf() Return the configuration used by this object.
String	getJournalsStatus() Get status information (e.g., whether formatted) of JournalNode's journals.
boolean	isStarted()
static void	main(String[] args)
int	run(String[] args) Execute the command with the given arguments.
void	setConf(Configuration conf) Set the configuration to be used by this object.
void	start() Start listening for edits via RPC.
void	stop(int rc) Stop the daemon with the given status code
void	stopAndJoin(int rc)

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

JournalNode

public JournalNode()

Method Detail

setConf

public void setConf(Configuration conf)

Description copied from interface: Configurable

Set the configuration to be used by this object.

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Description copied from interface: Configurable

Return the configuration used by this object.

Specified by:

getConf in interface Configurable

run

public int run(String[] args)
        throws Exception

Description copied from interface: Tool

Execute the command with the given arguments.

Specified by:

run in interface Tool

Parameters:

args - command specific arguments.

Returns:

exit code.

Throws:

Exception

start

public void start()
           throws IOException

Start listening for edits via RPC.

Throws:

IOException

isStarted

public boolean isStarted()

getBoundIpcAddress

public InetSocketAddress getBoundIpcAddress()

Returns:

the address the IPC server is bound to

getBoundHttpAddress

public InetSocketAddress getBoundHttpAddress()

stop

public void stop(int rc)

Stop the daemon with the given status code

Parameters:

rc - the status code with which to exit (non-zero should indicate an error)

stopAndJoin

public void stopAndJoin(int rc)
                 throws InterruptedException

Throws:

InterruptedException

getJournalsStatus

public String getJournalsStatus()

Description copied from interface: JournalNodeMXBean

Get status information (e.g., whether formatted) of JournalNode's journals.

Specified by:

getJournalsStatus in interface JournalNodeMXBean

Returns:

A string presenting status for each journal

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception