org.apache.hadoop.hbase.thrift

Class ThriftMetrics

java.lang.Object

org.apache.hadoop.hbase.thrift.ThriftMetrics

@InterfaceAudience.Private
public class ThriftMetrics
extends Object

This class is for maintaining the various statistics of thrift server and publishing them through the metrics interfaces.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThriftMetrics.ThriftServerType

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_SLOW_RESPONSE_NANO_SEC
static String	SLOW_RESPONSE_NANO_SEC
private long	slowResponseTime
private MetricsThriftServerSource	source

Constructor Summary

Constructors

Constructor and Description
ThriftMetrics(org.apache.hadoop.conf.Configuration conf, ThriftMetrics.ThriftServerType t)

Method Summary

Modifier and Type	Method and Description
void	decActiveWorkerCount()
void	exception(Throwable rawThrowable) Increment the count for a specific exception type.
MetricsThriftServerSource	getSource()
void	incActiveWorkerCount()
void	incMethodTime(String name, long time)
void	incNumRowKeysInBatchGet(int diff)
void	incNumRowKeysInBatchMutate(int diff)
void	incTimeInQueue(long time)
void	setCallQueueLen(int len)
void	setSource(MetricsThriftServerSource source)
private static Throwable	unwrap(Throwable t)

Methods inherited from class java.lang.Object

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

Field Detail

source

private MetricsThriftServerSource source

slowResponseTime

private final long slowResponseTime

SLOW_RESPONSE_NANO_SEC

public static final String SLOW_RESPONSE_NANO_SEC

See Also:

Constant Field Values

DEFAULT_SLOW_RESPONSE_NANO_SEC

public static final long DEFAULT_SLOW_RESPONSE_NANO_SEC

See Also:

Constant Field Values

Constructor Detail

ThriftMetrics

public ThriftMetrics(org.apache.hadoop.conf.Configuration conf,
                     ThriftMetrics.ThriftServerType t)

Method Detail

getSource

public MetricsThriftServerSource getSource()

setSource

public void setSource(MetricsThriftServerSource source)

incTimeInQueue

public void incTimeInQueue(long time)

setCallQueueLen

public void setCallQueueLen(int len)

incNumRowKeysInBatchGet

public void incNumRowKeysInBatchGet(int diff)

incNumRowKeysInBatchMutate

public void incNumRowKeysInBatchMutate(int diff)

incMethodTime

public void incMethodTime(String name,
                          long time)

incActiveWorkerCount

public void incActiveWorkerCount()

decActiveWorkerCount

public void decActiveWorkerCount()

exception

public void exception(Throwable rawThrowable)

Increment the count for a specific exception type. This is called for each exception type that is returned to the thrift handler.

Parameters:

rawThrowable - type of exception

unwrap

private static Throwable unwrap(Throwable t)