org.apache.hadoop.mapred

Class JobTrackerHAServiceTarget

java.lang.Object

org.apache.hadoop.ha.HAServiceTarget

org.apache.hadoop.mapred.JobTrackerHAServiceTarget

public class JobTrackerHAServiceTarget
extends org.apache.hadoop.ha.HAServiceTarget

Constructor Summary

Constructors

Constructor and Description
JobTrackerHAServiceTarget(org.apache.hadoop.conf.Configuration conf)
JobTrackerHAServiceTarget(org.apache.hadoop.conf.Configuration conf, java.lang.String jtId)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkFencingConfigured()
java.net.InetSocketAddress	getAddress()
org.apache.hadoop.ha.NodeFencer	getFencer()
java.lang.String	getJobTrackerId()
java.lang.String	getLogicalName()
java.net.InetSocketAddress	getZKFCAddress()
boolean	isAutoFailoverEnabled()
void	setZkfcPort(int port)
java.lang.String	toString()

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

addFencingParameters, getFencingParameters, getProxy, getZKFCProxy

Methods inherited from class java.lang.Object

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

Constructor Detail

JobTrackerHAServiceTarget

public JobTrackerHAServiceTarget(org.apache.hadoop.conf.Configuration conf)

JobTrackerHAServiceTarget

public JobTrackerHAServiceTarget(org.apache.hadoop.conf.Configuration conf,
                         java.lang.String jtId)

Method Detail

checkFencingConfigured

public void checkFencingConfigured()
                            throws org.apache.hadoop.ha.BadFencingConfigurationException

Specified by:

checkFencingConfigured in class org.apache.hadoop.ha.HAServiceTarget

Throws:

org.apache.hadoop.ha.BadFencingConfigurationException

getAddress

public java.net.InetSocketAddress getAddress()

Specified by:

getAddress in class org.apache.hadoop.ha.HAServiceTarget

getFencer

public org.apache.hadoop.ha.NodeFencer getFencer()

Specified by:

getFencer in class org.apache.hadoop.ha.HAServiceTarget

getZKFCAddress

public java.net.InetSocketAddress getZKFCAddress()

Specified by:

getZKFCAddress in class org.apache.hadoop.ha.HAServiceTarget

setZkfcPort

public void setZkfcPort(int port)

isAutoFailoverEnabled

public boolean isAutoFailoverEnabled()

Overrides:

isAutoFailoverEnabled in class org.apache.hadoop.ha.HAServiceTarget

getLogicalName

public java.lang.String getLogicalName()

getJobTrackerId

public java.lang.String getJobTrackerId()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object