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
private static org.slf4j.Logger	LOG
static String	SLOW_RESPONSE_NANO_SEC
protected long	slowResponseTime
protected MetricsThriftServerSource	source
private ThriftMetrics.ThriftServerType	thriftServerType

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()
ThriftMetrics.ThriftServerType	getThriftServerType()
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)
protected 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

LOG

private static final org.slf4j.Logger LOG

source

protected MetricsThriftServerSource source

slowResponseTime

protected 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

thriftServerType

private final ThriftMetrics.ThriftServerType thriftServerType

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

protected static Throwable unwrap(Throwable t)

getThriftServerType

public ThriftMetrics.ThriftServerType getThriftServerType()