org.apache.hadoop.mapred

Class JobTrackerHAServiceProtocol

java.lang.Object

org.apache.hadoop.mapred.JobTrackerHAServiceProtocol

All Implemented Interfaces:

org.apache.hadoop.ha.HAServiceProtocol

public class JobTrackerHAServiceProtocol
extends java.lang.Object
implements org.apache.hadoop.ha.HAServiceProtocol

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.ha.HAServiceProtocol

org.apache.hadoop.ha.HAServiceProtocol.HAServiceState, org.apache.hadoop.ha.HAServiceProtocol.RequestSource, org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SYSTEM_DIR_SEQUENCE_PREFIX

Fields inherited from interface org.apache.hadoop.ha.HAServiceProtocol

versionID

Constructor Summary

Constructors

Constructor and Description
JobTrackerHAServiceProtocol(org.apache.hadoop.conf.Configuration conf, JobTrackerHADaemon.JobTrackerRunner jtRunner)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.ha.HAServiceStatus	getServiceStatus()
void	monitorHealth()
void	stop()
void	transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
void	transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)

Methods inherited from class java.lang.Object

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

Field Detail

SYSTEM_DIR_SEQUENCE_PREFIX

public static final java.lang.String SYSTEM_DIR_SEQUENCE_PREFIX

See Also:

Constant Field Values

Constructor Detail

JobTrackerHAServiceProtocol

public JobTrackerHAServiceProtocol(org.apache.hadoop.conf.Configuration conf,
                           JobTrackerHADaemon.JobTrackerRunner jtRunner)

Method Detail

getServiceStatus

public org.apache.hadoop.ha.HAServiceStatus getServiceStatus()
                                                      throws org.apache.hadoop.security.AccessControlException,
                                                             java.io.IOException

Specified by:

getServiceStatus in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

org.apache.hadoop.security.AccessControlException

java.io.IOException

monitorHealth

public void monitorHealth()
                   throws org.apache.hadoop.ha.HealthCheckFailedException

Specified by:

monitorHealth in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

org.apache.hadoop.ha.HealthCheckFailedException

transitionToActive

public void transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
                        throws org.apache.hadoop.ha.ServiceFailedException,
                               org.apache.hadoop.security.AccessControlException,
                               java.io.IOException

Specified by:

transitionToActive in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

org.apache.hadoop.ha.ServiceFailedException

org.apache.hadoop.security.AccessControlException

java.io.IOException

transitionToStandby

public void transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
                         throws org.apache.hadoop.ha.ServiceFailedException,
                                org.apache.hadoop.security.AccessControlException,
                                java.io.IOException

Specified by:

transitionToStandby in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

org.apache.hadoop.ha.ServiceFailedException

org.apache.hadoop.security.AccessControlException

java.io.IOException

stop

public void stop()