public final class RegionClientStats extends Object
RegionClient
usage statistics.
This is an immutable snapshot of usage statistics of the region client. Please note that not all the numbers in the snapshot are collected atomically, so although each individual number is up-to-date as of the time this object is created, small inconsistencies between numbers can arise.
Modifier and Type | Method and Description |
---|---|
long |
inflightBreached()
The number of times RPCs were rejected due to there being too many RPCs
in flight and waiting for responses from the HBase server.
|
int |
inflightRPCs()
Represents the number of RPCs that have been sent to the region client
and are currently waiting for a response.
|
boolean |
isDead()
Whether or not this region client has been marked as dead and should not
be used for requests.
|
int |
pendingBatchedRPCs()
The number of batched RPCs waiting to be sent to the server.
|
long |
pendingBreached()
The number of times RPCs were rejected due to there being too many RPCs
in the pending queue, i.e.
|
int |
pendingRPCs()
The number of RPCs that are queued up and ready to be sent to the region
server.
|
String |
remoteEndpoint()
The remote endpoint of the region server this client is connecting to.
|
long |
rpcID()
The current RPC ID.
|
long |
rpcResponsesTimedout()
Represents the number of responses that were received from HBase for RPCs
that were already timed out by the client.
|
long |
rpcResponsesUnknown()
Represents the number of responses that were received from HBase that
were for RPCs the region client supposedly did not send.
|
long |
rpcsSent()
Represents the total number of RPCs sent from this client to the server,
whether they were successful or not.
|
long |
rpcsTimedout()
The number of RPCs that timed out due to not receiving a response from
HBase in a configurable amount of time.
|
long |
writesBlocked()
The number of times sending an RPC was blocked due to the socket send
buffer being full.
|
public long rpcsSent()
public int inflightRPCs()
public int pendingRPCs()
rpcsInFlight
incremented.public long rpcID()
public boolean isDead()
public String remoteEndpoint()
public int pendingBatchedRPCs()
public long rpcsTimedout()
public long writesBlocked()
public long rpcResponsesTimedout()
public long rpcResponsesUnknown()
public long inflightBreached()
PleaseThrottleException
public long pendingBreached()
PleaseThrottleException
Copyright © 2010-2017, The Async HBase Authors