org.apache.hadoop.chukwa.datacollection.agent.metrics

Class ChunkQueueMetrics

java.lang.Object

org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

All Implemented Interfaces:

org.apache.hadoop.metrics.Updater

public class ChunkQueueMetrics
extends Object
implements org.apache.hadoop.metrics.Updater

Field Summary

Fields

Modifier and Type	Field and Description
org.apache.hadoop.metrics.util.MetricsTimeVaryingInt	addedChunk
org.apache.hadoop.metrics.util.MetricsLongValue	dataSize
org.apache.hadoop.metrics.util.MetricsIntValue	fullQueue
org.apache.hadoop.metrics.util.MetricsIntValue	queueSize
org.apache.hadoop.metrics.util.MetricsRegistry	registry
org.apache.hadoop.metrics.util.MetricsTimeVaryingInt	removedChunk

Constructor Summary

Constructors

Constructor and Description
ChunkQueueMetrics(String processName, String recordName) Creates a new instance of QueueMetrics

Method Summary

Methods

Modifier and Type	Method and Description
void	doUpdates(org.apache.hadoop.metrics.MetricsContext unused) Since this object is a registered updater, this method will be called periodically, e.g.
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

registry

public org.apache.hadoop.metrics.util.MetricsRegistry registry

queueSize

public org.apache.hadoop.metrics.util.MetricsIntValue queueSize

dataSize

public org.apache.hadoop.metrics.util.MetricsLongValue dataSize

addedChunk

public org.apache.hadoop.metrics.util.MetricsTimeVaryingInt addedChunk

removedChunk

public org.apache.hadoop.metrics.util.MetricsTimeVaryingInt removedChunk

fullQueue

public org.apache.hadoop.metrics.util.MetricsIntValue fullQueue

Constructor Detail

ChunkQueueMetrics

public ChunkQueueMetrics(String processName,
                 String recordName)

Creates a new instance of QueueMetrics

Method Detail

doUpdates

public void doUpdates(org.apache.hadoop.metrics.MetricsContext unused)

Since this object is a registered updater, this method will be called periodically, e.g. every 5 seconds.

Specified by:

doUpdates in interface org.apache.hadoop.metrics.Updater

shutdown

public void shutdown()