org.apache.hadoop.hbase.quotas

Class RpcThrottleStorage

java.lang.Object

org.apache.hadoop.hbase.quotas.RpcThrottleStorage

@InterfaceAudience.Private
public class RpcThrottleStorage
extends Object

ZK based rpc throttle storage.

Field Summary

Fields

Modifier and Type	Field and Description
static String	RPC_THROTTLE_ZNODE
static String	RPC_THROTTLE_ZNODE_DEFAULT
private String	rpcThrottleZNode
private ZKWatcher	zookeeper

Constructor Summary

Constructors

Constructor and Description
RpcThrottleStorage(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
boolean	isRpcThrottleEnabled()
void	switchRpcThrottle(boolean enable) Store the rpc throttle value.

Methods inherited from class java.lang.Object

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

Field Detail

RPC_THROTTLE_ZNODE

public static final String RPC_THROTTLE_ZNODE

See Also:

Constant Field Values

RPC_THROTTLE_ZNODE_DEFAULT

public static final String RPC_THROTTLE_ZNODE_DEFAULT

See Also:

Constant Field Values

zookeeper

private final ZKWatcher zookeeper

rpcThrottleZNode

private final String rpcThrottleZNode

Constructor Detail

RpcThrottleStorage

public RpcThrottleStorage(ZKWatcher zookeeper,
                          org.apache.hadoop.conf.Configuration conf)

Method Detail

isRpcThrottleEnabled

public boolean isRpcThrottleEnabled()
                             throws IOException

Throws:

IOException

switchRpcThrottle

public void switchRpcThrottle(boolean enable)
                       throws IOException

Store the rpc throttle value.

Parameters:

enable - Set to true to enable, false to disable.

Throws:

IOException - if an unexpected io exception occurs