org.apache.hadoop.mapred.tools

Class MRZKFailoverController

java.lang.Object

org.apache.hadoop.ha.ZKFailoverController

org.apache.hadoop.mapred.tools.MRZKFailoverController

@InterfaceAudience.Private
public class MRZKFailoverController
extends org.apache.hadoop.ha.ZKFailoverController

Field Summary

Fields inherited from class org.apache.hadoop.ha.ZKFailoverController

conf, localTarget, rpcServer, USAGE, ZK_ACL_KEY, ZK_AUTH_KEY, ZK_QUORUM_KEY, ZKFC_CONF_KEYS

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkRpcAdminAccess()
static MRZKFailoverController	create(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.ha.HAServiceTarget	dataToTarget(byte[] data)
protected org.apache.hadoop.security.authorize.PolicyProvider	getPolicyProvider()
protected java.net.InetSocketAddress	getRpcAddressToBindTo()
protected java.lang.String	getScopeInsideParentNode()
static int	getZkfcPort(org.apache.hadoop.conf.Configuration conf)
protected void	initRPC()
void	loginAsFCUser()
static void	main(java.lang.String[] args)
protected byte[]	targetToData(org.apache.hadoop.ha.HAServiceTarget target)

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

getLastHealthState, getLocalTarget, run, setLastHealthState, startRPC

Methods inherited from class java.lang.Object

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

Method Detail

dataToTarget

protected org.apache.hadoop.ha.HAServiceTarget dataToTarget(byte[] data)

Specified by:

dataToTarget in class org.apache.hadoop.ha.ZKFailoverController

targetToData

protected byte[] targetToData(org.apache.hadoop.ha.HAServiceTarget target)

Specified by:

targetToData in class org.apache.hadoop.ha.ZKFailoverController

getRpcAddressToBindTo

protected java.net.InetSocketAddress getRpcAddressToBindTo()

Specified by:

getRpcAddressToBindTo in class org.apache.hadoop.ha.ZKFailoverController

getPolicyProvider

protected org.apache.hadoop.security.authorize.PolicyProvider getPolicyProvider()

Specified by:

getPolicyProvider in class org.apache.hadoop.ha.ZKFailoverController

getZkfcPort

public static int getZkfcPort(org.apache.hadoop.conf.Configuration conf)

create

public static MRZKFailoverController create(org.apache.hadoop.conf.Configuration conf)

initRPC

protected void initRPC()
                throws java.io.IOException

Overrides:

initRPC in class org.apache.hadoop.ha.ZKFailoverController

Throws:

java.io.IOException

loginAsFCUser

public void loginAsFCUser()
                   throws java.io.IOException

Specified by:

loginAsFCUser in class org.apache.hadoop.ha.ZKFailoverController

Throws:

java.io.IOException

getScopeInsideParentNode

protected java.lang.String getScopeInsideParentNode()

Specified by:

getScopeInsideParentNode in class org.apache.hadoop.ha.ZKFailoverController

main

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

Throws:

java.lang.Exception

checkRpcAdminAccess

protected void checkRpcAdminAccess()
                            throws java.io.IOException,
                                   org.apache.hadoop.security.AccessControlException

Specified by:

checkRpcAdminAccess in class org.apache.hadoop.ha.ZKFailoverController

Throws:

java.io.IOException

org.apache.hadoop.security.AccessControlException