Package org.apache.hadoop.hbase.quotas

Class RpcThrottleStorage

java.lang.Object

org.apache.hadoop.hbase.quotas.RpcThrottleStorage

@Private
public class RpcThrottleStorage
extends Object

ZK based rpc throttle storage.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

RpcThrottleStorage

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

Method Details

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