org.apache.hadoop.hdfs.tools

Class NNHAServiceTarget

java.lang.Object

org.apache.hadoop.ha.HAServiceTarget

org.apache.hadoop.hdfs.tools.NNHAServiceTarget

@InterfaceAudience.Private
public class NNHAServiceTarget
extends HAServiceTarget

One of the NN NameNodes acting as the target of an administrative command (e.g. failover).

Constructor Summary

Constructors

Constructor and Description
NNHAServiceTarget(Configuration conf, String nsId, String nnId)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addFencingParameters(Map<String,String> ret) Hook to allow subclasses to add any parameters they would like to expose to fencing implementations/scripts.
void	checkFencingConfigured()
InetSocketAddress	getAddress()
NodeFencer	getFencer()
String	getNameNodeId()
String	getNameServiceId()
InetSocketAddress	getZKFCAddress()
boolean	isAutoFailoverEnabled()
String	toString()

Methods inherited from class org.apache.hadoop.ha.HAServiceTarget

getFencingParameters, getProxy, getZKFCProxy

Methods inherited from class java.lang.Object

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

Constructor Detail

NNHAServiceTarget

public NNHAServiceTarget(Configuration conf,
                 String nsId,
                 String nnId)

Method Detail

getAddress

public InetSocketAddress getAddress()

Specified by:

getAddress in class HAServiceTarget

Returns:

the NN's IPC address.

getZKFCAddress

public InetSocketAddress getZKFCAddress()

Specified by:

getZKFCAddress in class HAServiceTarget

Returns:

the IPC address of the ZKFC on the target node

checkFencingConfigured

public void checkFencingConfigured()
                            throws BadFencingConfigurationException

Specified by:

checkFencingConfigured in class HAServiceTarget

Throws:

BadFencingConfigurationException - if the fencing configuration appears to be invalid. This is divorced from the above HAServiceTarget.getFencer() method so that the configuration can be checked during the pre-flight phase of failover.

getFencer

public NodeFencer getFencer()

Specified by:

getFencer in class HAServiceTarget

Returns:

a Fencer implementation configured for this target node

toString

public String toString()

Overrides:

toString in class Object

getNameServiceId

public String getNameServiceId()

getNameNodeId

public String getNameNodeId()

addFencingParameters

protected void addFencingParameters(Map<String,String> ret)

Description copied from class: HAServiceTarget

Hook to allow subclasses to add any parameters they would like to expose to fencing implementations/scripts. Fencing methods are free to use this map as they see fit -- notably, the shell script implementation takes each entry, prepends 'target_', substitutes '_' for '.', and adds it to the environment of the script. Subclass implementations should be sure to delegate to the superclass implementation as well as adding their own keys.

Overrides:

addFencingParameters in class HAServiceTarget

Parameters:

ret - map which can be mutated to pass parameters to the fencer

isAutoFailoverEnabled

public boolean isAutoFailoverEnabled()

Overrides:

isAutoFailoverEnabled in class HAServiceTarget

Returns:

true if auto failover should be considered enabled