org.apache.hadoop.dfs.datanode.metrics
Class DataNodeMetrics

java.lang.Object
  org.apache.hadoop.dfs.datanode.metrics.DataNodeMetrics

All Implemented Interfaces:

Updater

public class DataNodeMetrics
extends Object
implements Updater

This class is for maintaining the various DataNode statistics and publishing them through the metrics interfaces. This also registers the JMX MBean for RPC.

This class has a number of metrics variables that are publicly accessible; these variables (objects) have methods to update their values; for example:

blocksRead.inc()

Field Summary

MetricsTimeVaryingRate	blockReports
MetricsTimeVaryingInt	blocksRead
MetricsTimeVaryingInt	blocksRemoved
MetricsTimeVaryingInt	blocksReplicated
MetricsTimeVaryingInt	blocksVerified
MetricsTimeVaryingInt	blocksWritten
MetricsTimeVaryingInt	blockVerificationFailures
MetricsTimeVaryingInt	bytesRead
MetricsTimeVaryingInt	bytesWritten
MetricsTimeVaryingRate	copyBlockOp
MetricsTimeVaryingRate	heartbeats
MetricsTimeVaryingRate	readBlockOp
MetricsTimeVaryingRate	readMetadataOp
MetricsTimeVaryingInt	readsFromLocalClient
MetricsTimeVaryingInt	readsFromRemoteClient
MetricsTimeVaryingRate	replaceBlockOp
MetricsTimeVaryingRate	writeBlockOp
MetricsTimeVaryingInt	writesFromLocalClient
MetricsTimeVaryingInt	writesFromRemoteClient

Constructor Summary

DataNodeMetrics(Configuration conf, String storageId)

Method Summary

void	doUpdates(MetricsContext unused) Since this object is a registered updater, this method will be called periodically, e.g.
void	resetAllMinMax()
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

bytesWritten

public MetricsTimeVaryingInt bytesWritten

bytesRead

public MetricsTimeVaryingInt bytesRead

blocksWritten

public MetricsTimeVaryingInt blocksWritten

blocksRead

public MetricsTimeVaryingInt blocksRead

blocksReplicated

public MetricsTimeVaryingInt blocksReplicated

blocksRemoved

public MetricsTimeVaryingInt blocksRemoved

blocksVerified

public MetricsTimeVaryingInt blocksVerified

blockVerificationFailures

public MetricsTimeVaryingInt blockVerificationFailures

readsFromLocalClient

public MetricsTimeVaryingInt readsFromLocalClient

readsFromRemoteClient

public MetricsTimeVaryingInt readsFromRemoteClient

writesFromLocalClient

public MetricsTimeVaryingInt writesFromLocalClient

writesFromRemoteClient

public MetricsTimeVaryingInt writesFromRemoteClient

readBlockOp

public MetricsTimeVaryingRate readBlockOp

writeBlockOp

public MetricsTimeVaryingRate writeBlockOp

readMetadataOp

public MetricsTimeVaryingRate readMetadataOp

copyBlockOp

public MetricsTimeVaryingRate copyBlockOp

replaceBlockOp

public MetricsTimeVaryingRate replaceBlockOp

heartbeats

public MetricsTimeVaryingRate heartbeats

blockReports

public MetricsTimeVaryingRate blockReports

Constructor Detail

DataNodeMetrics

public DataNodeMetrics(Configuration conf,
                       String storageId)

Method Detail

shutdown

public void shutdown()

doUpdates

public void doUpdates(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 Updater

resetAllMinMax

public void resetAllMinMax()