org.apache.hadoop.hive.common.metrics.metrics2

Class CodahaleMetrics

java.lang.Object

org.apache.hadoop.hive.common.metrics.metrics2.CodahaleMetrics

All Implemented Interfaces:

Metrics

public class CodahaleMetrics
extends Object
implements Metrics

Codahale-backed Metrics implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CodahaleMetrics.CodahaleMetricsScope

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOGGER
com.codahale.metrics.MetricRegistry	metricRegistry

Constructor Summary

Constructors

Constructor and Description
CodahaleMetrics(HiveConf conf)

Method Summary

Modifier and Type	Method and Description
void	addGauge(String name, MetricsVariable variable) Adds a metrics-gauge to track variable.
void	addRatio(String name, MetricsVariable<Integer> numerator, MetricsVariable<Integer> denominator) Add a ratio metric to track the correlation between two variables
void	close() Deinitializes the Metrics system.
MetricsScope	createScope(String name) Create scope with given name and returns it.
Long	decrementCounter(String name) Decrements a counter of the given name by 1.
Long	decrementCounter(String name, long decrement) Decrements a counter of the given name by "decrement"
String	dumpJson()
void	endScope(MetricsScope scope) Close the given scope.
void	endStoredScope(String name) Closes the stored scope of a given name.
com.codahale.metrics.MetricRegistry	getMetricRegistry()
MetricsScope	getStoredScope(String name)
Long	incrementCounter(String name) Increments a counter of the given name by 1.
Long	incrementCounter(String name, long increment) Increments a counter of the given name by "increment"
void	markMeter(String name) Mark an event occurance for a meter.
void	removeGauge(String name) Removed the gauge added by addGauge.
void	startStoredScope(String name)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

public static final org.slf4j.Logger LOGGER

metricRegistry

public final com.codahale.metrics.MetricRegistry metricRegistry

Constructor Detail

CodahaleMetrics

public CodahaleMetrics(HiveConf conf)

Method Detail

close

public void close()
           throws Exception

Description copied from interface: Metrics

Deinitializes the Metrics system.

Specified by:

close in interface Metrics

Throws:

Exception

startStoredScope

public void startStoredScope(String name)

Specified by:

startStoredScope in interface Metrics

Parameters:

name - starts a scope of a given name. Scopes is stored as thread-local variable.

endStoredScope

public void endStoredScope(String name)

Description copied from interface: Metrics

Closes the stored scope of a given name. Note that this must be called on the same thread as where the scope was started.

Specified by:

endStoredScope in interface Metrics

getStoredScope

public MetricsScope getStoredScope(String name)
                            throws IllegalArgumentException

Throws:

IllegalArgumentException

createScope

public MetricsScope createScope(String name)

Description copied from interface: Metrics

Create scope with given name and returns it.

Specified by:

createScope in interface Metrics

Returns:

endScope

public void endScope(MetricsScope scope)

Description copied from interface: Metrics

Close the given scope.

Specified by:

endScope in interface Metrics

incrementCounter

public Long incrementCounter(String name)

Description copied from interface: Metrics

Increments a counter of the given name by 1.

Specified by:

incrementCounter in interface Metrics

Returns:

incrementCounter

public Long incrementCounter(String name,
                             long increment)

Description copied from interface: Metrics

Increments a counter of the given name by "increment"

Specified by:

incrementCounter in interface Metrics

Returns:

decrementCounter

public Long decrementCounter(String name)

Description copied from interface: Metrics

Decrements a counter of the given name by 1.

Specified by:

decrementCounter in interface Metrics

Returns:

decrementCounter

public Long decrementCounter(String name,
                             long decrement)

Description copied from interface: Metrics

Decrements a counter of the given name by "decrement"

Specified by:

decrementCounter in interface Metrics

Returns:

addGauge

public void addGauge(String name,
                     MetricsVariable variable)

Description copied from interface: Metrics

Adds a metrics-gauge to track variable. For example, number of open database connections.

Specified by:

addGauge in interface Metrics

Parameters:

name - name of gauge

variable - variable to track.

removeGauge

public void removeGauge(String name)

Description copied from interface: Metrics

Removed the gauge added by addGauge.

Specified by:

removeGauge in interface Metrics

Parameters:

name - name of gauge

addRatio

public void addRatio(String name,
                     MetricsVariable<Integer> numerator,
                     MetricsVariable<Integer> denominator)

Description copied from interface: Metrics

Add a ratio metric to track the correlation between two variables

Specified by:

addRatio in interface Metrics

Parameters:

name - name of the ratio gauge

numerator - numerator of the ratio

denominator - denominator of the ratio

markMeter

public void markMeter(String name)

Description copied from interface: Metrics

Mark an event occurance for a meter. Meters measure the rate of an event and track 1/5/15 minute moving averages

Specified by:

markMeter in interface Metrics

Parameters:

name - name of the meter

getMetricRegistry

public com.codahale.metrics.MetricRegistry getMetricRegistry()

dumpJson

public String dumpJson()
                throws Exception

Throws:

Exception