Package org.apache.hadoop.hbase.ipc

Class MetricsHBaseServerWrapperImpl

java.lang.Object

org.apache.hadoop.hbase.ipc.MetricsHBaseServerWrapperImpl

All Implemented Interfaces:

MetricsHBaseServerWrapper

@Private
public class MetricsHBaseServerWrapperImpl
extends Object
implements MetricsHBaseServerWrapper

Field Summary

Fields

Modifier and Type	Field	Description
private RpcServer	server

Constructor Summary

Constructors

Constructor	Description
MetricsHBaseServerWrapperImpl(RpcServer server)

Method Summary

Modifier and Type	Method	Description
int	getActiveBulkLoadRpcHandlerCount()
int	getActiveGeneralRpcHandlerCount()
int	getActiveMetaPriorityRpcHandlerCount()
int	getActivePriorityRpcHandlerCount()
int	getActiveReadRpcHandlerCount()
int	getActiveReplicationRpcHandlerCount()
int	getActiveRpcHandlerCount()
int	getActiveScanRpcHandlerCount()
int	getActiveWriteRpcHandlerCount()
int	getBulkLoadQueueLength()
int	getGeneralQueueLength()
int	getMetaPriorityQueueLength()
long	getNettyDmUsage()
long	getNumGeneralCallsDropped()
long	getNumLifoModeSwitches()
int	getNumOpenConnections()
int	getPriorityQueueLength()
int	getReadQueueLength()
int	getReplicationQueueLength()
int	getScanQueueLength()
Pair<Long,Long>	getTotalAndMaxNettyOutboundBytes()	These two metrics are calculated together, so we want to return them in one call
long	getTotalQueueSize()
int	getWriteQueueLength()
private boolean	isServerStarted()

Methods inherited from class java.lang.Object

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

Field Details

server

private RpcServer server

Constructor Details

MetricsHBaseServerWrapperImpl

MetricsHBaseServerWrapperImpl(RpcServer server)

Method Details

isServerStarted

private boolean isServerStarted()

getTotalQueueSize

public long getTotalQueueSize()

Specified by:

getTotalQueueSize in interface MetricsHBaseServerWrapper

getGeneralQueueLength

public int getGeneralQueueLength()

Specified by:

getGeneralQueueLength in interface MetricsHBaseServerWrapper

getReplicationQueueLength

public int getReplicationQueueLength()

Specified by:

getReplicationQueueLength in interface MetricsHBaseServerWrapper

getBulkLoadQueueLength

public int getBulkLoadQueueLength()

Specified by:

getBulkLoadQueueLength in interface MetricsHBaseServerWrapper

getPriorityQueueLength

public int getPriorityQueueLength()

Specified by:

getPriorityQueueLength in interface MetricsHBaseServerWrapper

getMetaPriorityQueueLength

public int getMetaPriorityQueueLength()

Specified by:

getMetaPriorityQueueLength in interface MetricsHBaseServerWrapper

getNumOpenConnections

public int getNumOpenConnections()

Specified by:

getNumOpenConnections in interface MetricsHBaseServerWrapper

getActiveRpcHandlerCount

public int getActiveRpcHandlerCount()

Specified by:

getActiveRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveGeneralRpcHandlerCount

public int getActiveGeneralRpcHandlerCount()

Specified by:

getActiveGeneralRpcHandlerCount in interface MetricsHBaseServerWrapper

getActivePriorityRpcHandlerCount

public int getActivePriorityRpcHandlerCount()

Specified by:

getActivePriorityRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveMetaPriorityRpcHandlerCount

public int getActiveMetaPriorityRpcHandlerCount()

Specified by:

getActiveMetaPriorityRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveReplicationRpcHandlerCount

public int getActiveReplicationRpcHandlerCount()

Specified by:

getActiveReplicationRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveBulkLoadRpcHandlerCount

public int getActiveBulkLoadRpcHandlerCount()

Specified by:

getActiveBulkLoadRpcHandlerCount in interface MetricsHBaseServerWrapper

getNumGeneralCallsDropped

public long getNumGeneralCallsDropped()

Specified by:

getNumGeneralCallsDropped in interface MetricsHBaseServerWrapper

getNumLifoModeSwitches

public long getNumLifoModeSwitches()

Specified by:

getNumLifoModeSwitches in interface MetricsHBaseServerWrapper

getWriteQueueLength

public int getWriteQueueLength()

Specified by:

getWriteQueueLength in interface MetricsHBaseServerWrapper

getReadQueueLength

public int getReadQueueLength()

Specified by:

getReadQueueLength in interface MetricsHBaseServerWrapper

getScanQueueLength

public int getScanQueueLength()

Specified by:

getScanQueueLength in interface MetricsHBaseServerWrapper

getActiveWriteRpcHandlerCount

public int getActiveWriteRpcHandlerCount()

Specified by:

getActiveWriteRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveReadRpcHandlerCount

public int getActiveReadRpcHandlerCount()

Specified by:

getActiveReadRpcHandlerCount in interface MetricsHBaseServerWrapper

getActiveScanRpcHandlerCount

public int getActiveScanRpcHandlerCount()

Specified by:

getActiveScanRpcHandlerCount in interface MetricsHBaseServerWrapper

getNettyDmUsage

public long getNettyDmUsage()

Specified by:

getNettyDmUsage in interface MetricsHBaseServerWrapper

getTotalAndMaxNettyOutboundBytes

public Pair<Long,Long> getTotalAndMaxNettyOutboundBytes()

Description copied from interface: MetricsHBaseServerWrapper

These two metrics are calculated together, so we want to return them in one call

Specified by:

getTotalAndMaxNettyOutboundBytes in interface MetricsHBaseServerWrapper

Returns:

pair containing total (first) and max (second) pending outbound bytes.