@InterfaceAudience.Private
public class MRZKFailoverController
extends org.apache.hadoop.ha.ZKFailoverController
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) |
protected org.apache.hadoop.ha.HAServiceTarget dataToTarget(byte[] data)
dataToTarget
in class org.apache.hadoop.ha.ZKFailoverController
protected byte[] targetToData(org.apache.hadoop.ha.HAServiceTarget target)
targetToData
in class org.apache.hadoop.ha.ZKFailoverController
protected java.net.InetSocketAddress getRpcAddressToBindTo()
getRpcAddressToBindTo
in class org.apache.hadoop.ha.ZKFailoverController
protected org.apache.hadoop.security.authorize.PolicyProvider getPolicyProvider()
getPolicyProvider
in class org.apache.hadoop.ha.ZKFailoverController
public static int getZkfcPort(org.apache.hadoop.conf.Configuration conf)
public static MRZKFailoverController create(org.apache.hadoop.conf.Configuration conf)
protected void initRPC() throws java.io.IOException
initRPC
in class org.apache.hadoop.ha.ZKFailoverController
java.io.IOException
public void loginAsFCUser() throws java.io.IOException
loginAsFCUser
in class org.apache.hadoop.ha.ZKFailoverController
java.io.IOException
protected java.lang.String getScopeInsideParentNode()
getScopeInsideParentNode
in class org.apache.hadoop.ha.ZKFailoverController
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
protected void checkRpcAdminAccess() throws java.io.IOException, org.apache.hadoop.security.AccessControlException
checkRpcAdminAccess
in class org.apache.hadoop.ha.ZKFailoverController
java.io.IOException
org.apache.hadoop.security.AccessControlException
Copyright © 2009 The Apache Software Foundation