org.apache.hadoop.hdfs.tools

Class DFSZKFailoverController

java.lang.Object

org.apache.hadoop.ha.ZKFailoverController

org.apache.hadoop.hdfs.tools.DFSZKFailoverController

@InterfaceAudience.Private
public class DFSZKFailoverController
extends 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 DFSZKFailoverController	create(Configuration conf)
protected HAServiceTarget	dataToTarget(byte[] data)
protected PolicyProvider	getPolicyProvider()
protected InetSocketAddress	getRpcAddressToBindTo()
protected String	getScopeInsideParentNode() Return the name of a znode inside the configured parent znode in which the ZKFC will do all of its work.
protected void	initRPC()
void	loginAsFCUser()
static void	main(String[] args)
protected byte[]	targetToData(HAServiceTarget target)

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

getLocalTarget, run, startRPC

Methods inherited from class java.lang.Object

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

Method Detail

dataToTarget

protected HAServiceTarget dataToTarget(byte[] data)

Specified by:

dataToTarget in class ZKFailoverController

targetToData

protected byte[] targetToData(HAServiceTarget target)

Specified by:

targetToData in class ZKFailoverController

getRpcAddressToBindTo

protected InetSocketAddress getRpcAddressToBindTo()

Specified by:

getRpcAddressToBindTo in class ZKFailoverController

getPolicyProvider

protected PolicyProvider getPolicyProvider()

Specified by:

getPolicyProvider in class ZKFailoverController

create

public static DFSZKFailoverController create(Configuration conf)

initRPC

protected void initRPC()
                throws IOException

Overrides:

initRPC in class ZKFailoverController

Throws:

IOException

loginAsFCUser

public void loginAsFCUser()
                   throws IOException

Specified by:

loginAsFCUser in class ZKFailoverController

Throws:

IOException

getScopeInsideParentNode

protected String getScopeInsideParentNode()

Description copied from class: ZKFailoverController

Return the name of a znode inside the configured parent znode in which the ZKFC will do all of its work. This is so that multiple federated nameservices can run on the same ZK quorum without having to manually configure them to separate subdirectories.

Specified by:

getScopeInsideParentNode in class ZKFailoverController

main

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

Throws:

Exception

checkRpcAdminAccess

protected void checkRpcAdminAccess()
                            throws IOException,
                                   AccessControlException

Specified by:

checkRpcAdminAccess in class ZKFailoverController

Throws:

IOException

AccessControlException