Package org.apache.hadoop.ipc.metrics

Class RpcDetailedMetrics

java.lang.Object

org.apache.hadoop.ipc.metrics.RpcDetailedMetrics

@Private
@Metrics(about="Per method RPC metrics",
         context="rpcdetailed")
public class RpcDetailedMetrics
extends Object

This class is for maintaining RPC method related statistics and publishing them through the metrics interfaces.

Method Summary

Modifier and Type	Method	Description
void	addDeferredProcessingTime(String name, long processingTime)
void	addOverallProcessingTime(String rpcCallName, long overallProcessingTime)	Add an overall RPC processing time sample.
void	addProcessingTime(String rpcCallName, long processingTime)	Add an RPC processing time sample
static RpcDetailedMetrics	create(int port)
MutableRatesWithAggregation	getOverallRpcProcessingRates()
void	init(Class<?> protocol)	Initialize the metrics for JMX with protocol methods
String	name()
void	shutdown()	Shutdown the instrumentation for the process

Methods inherited from class java.lang.Object

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

Method Details

getOverallRpcProcessingRates

public MutableRatesWithAggregation getOverallRpcProcessingRates()

name

public String name()

create

public static RpcDetailedMetrics create(int port)

init

public void init(Class<?> protocol)

Initialize the metrics for JMX with protocol methods

Parameters:

protocol - the protocol class

addProcessingTime

public void addProcessingTime(String rpcCallName,
 long processingTime)

Add an RPC processing time sample

Parameters:

rpcCallName - of the RPC call

processingTime - the processing time

addDeferredProcessingTime

public void addDeferredProcessingTime(String name,
 long processingTime)

addOverallProcessingTime

public void addOverallProcessingTime(String rpcCallName,
 long overallProcessingTime)

Add an overall RPC processing time sample.

Parameters:

rpcCallName - of the RPC call

overallProcessingTime - the overall RPC processing time

shutdown

public void shutdown()

Shutdown the instrumentation for the process