Package org.apache.hadoop.ipc

Class DecayRpcScheduler.MetricsProxy

java.lang.Object

org.apache.hadoop.ipc.DecayRpcScheduler.MetricsProxy

All Implemented Interfaces:

DecayRpcSchedulerMXBean, MetricsSource

Enclosing class:

DecayRpcScheduler

public static final class DecayRpcScheduler.MetricsProxy
extends Object
implements DecayRpcSchedulerMXBean, MetricsSource

MetricsProxy is a singleton because we may init multiple schedulers and we want to clean up resources when a new scheduler replaces the old one.

Method Summary

Modifier and Type	Method	Description
double[]	getAverageResponseTime()
String	getCallVolumeSummary()
static DecayRpcScheduler.MetricsProxy	getInstance(String namespace, int numLevels, DecayRpcScheduler drs)
void	getMetrics(MetricsCollector collector, boolean all)	Get metrics from the metrics source
long[]	getResponseTimeCountInLastWindow()
String	getSchedulingDecisionSummary()
long	getTotalCallVolume()
int	getUniqueIdentityCount()
static void	removeInstance(String namespace)
void	setDelegate(DecayRpcScheduler obj)

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static DecayRpcScheduler.MetricsProxy getInstance(String namespace,
 int numLevels,
 DecayRpcScheduler drs)

removeInstance

public static void removeInstance(String namespace)

setDelegate

public void setDelegate(DecayRpcScheduler obj)

getSchedulingDecisionSummary

public String getSchedulingDecisionSummary()

Specified by:

getSchedulingDecisionSummary in interface DecayRpcSchedulerMXBean

getCallVolumeSummary

public String getCallVolumeSummary()

Specified by:

getCallVolumeSummary in interface DecayRpcSchedulerMXBean

getUniqueIdentityCount

public int getUniqueIdentityCount()

Specified by:

getUniqueIdentityCount in interface DecayRpcSchedulerMXBean

getTotalCallVolume

public long getTotalCallVolume()

Specified by:

getTotalCallVolume in interface DecayRpcSchedulerMXBean

getAverageResponseTime

public double[] getAverageResponseTime()

Specified by:

getAverageResponseTime in interface DecayRpcSchedulerMXBean

getResponseTimeCountInLastWindow

public long[] getResponseTimeCountInLastWindow()

Specified by:

getResponseTimeCountInLastWindow in interface DecayRpcSchedulerMXBean

getMetrics

public void getMetrics(MetricsCollector collector,
 boolean all)

Description copied from interface: MetricsSource

Get metrics from the metrics source

Specified by:

getMetrics in interface MetricsSource

Parameters:

collector - to contain the resulting metrics snapshot

all - if true, return all metrics even if unchanged.