Package org.apache.hadoop.hbase.quotas

Class RpcThrottleStateStore

java.lang.Object

org.apache.hadoop.hbase.master.MasterStateStore

org.apache.hadoop.hbase.master.BooleanStateStore

org.apache.hadoop.hbase.quotas.RpcThrottleStateStore

@Private
public class RpcThrottleStateStore
extends BooleanStateStore

Store whether rpc throttle is enabled.

Notice that, this is stored in master local region so only master can read it. For region servers, we will publish the change through SwitchRpcThrottleProcedure and region servers can also query the flag through rpc request to master.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	RPC_THROTTLE_ZNODE
static final String	RPC_THROTTLE_ZNODE_DEFAULT
static final String	STATE_NAME

Constructor Summary

Constructors

Constructor	Description
RpcThrottleStateStore(MasterRegion masterRegion, ZKWatcher watcher, String zkPath)

Method Summary

Modifier and Type	Method	Description
protected boolean	parseFrom(byte[] bytes)
protected byte[]	toByteArray(boolean on)

Methods inherited from class org.apache.hadoop.hbase.master.BooleanStateStore

get, set

Methods inherited from class org.apache.hadoop.hbase.master.MasterStateStore

getState, setState

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

STATE_NAME

public static final String STATE_NAME

See Also:

• Constant Field Values

Constructor Details

RpcThrottleStateStore

public RpcThrottleStateStore(MasterRegion masterRegion,
 ZKWatcher watcher,
 String zkPath)
                      throws IOException,
org.apache.zookeeper.KeeperException,
DeserializationException

Throws:

IOException

org.apache.zookeeper.KeeperException

DeserializationException

Method Details

toByteArray

protected byte[] toByteArray(boolean on)

Specified by:

toByteArray in class BooleanStateStore

parseFrom

protected boolean parseFrom(byte[] bytes)
                     throws DeserializationException

Specified by:

parseFrom in class BooleanStateStore

Throws:

DeserializationException