Package org.apache.hadoop.ipc.metrics

Class DecayRpcSchedulerDetailedMetrics

java.lang.Object
org.apache.hadoop.ipc.metrics.DecayRpcSchedulerDetailedMetrics
@Private @Evolving @Metrics(about="Per queue(priority) metrics", context="decayrpcschedulerdetailed") public class DecayRpcSchedulerDetailedMetrics extends Object
This class is for maintaining queue (priority) level related statistics when FairCallQueue is used and publishing them through the metrics interface.

  • Method Details

    • create

      public static DecayRpcSchedulerDetailedMetrics create(String ns)

    • init

      public void init(int numLevels)
      Initialize the metrics for JMX with priority levels.
      Parameters:
      numLevels - input numLevels.

    • addQueueTime

      public void addQueueTime(int priority, long queueTime)
      Instrument a Call queue time based on its priority.
      Parameters:
      priority - of the RPC call
      queueTime - of the RPC call in the queue of the priority

    • addProcessingTime

      public void addProcessingTime(int priority, long processingTime)
      Instrument a Call processing time based on its priority.
      Parameters:
      priority - of the RPC call
      processingTime - of the RPC call in the queue of the priority

    • shutdown

      public void shutdown()
      Shutdown the instrumentation process.

    • getQueueName

      public String getQueueName(int priority)
      Parameters:
      priority - input priority.
      Returns:
      Returns the rate name inside the metric.

    • getProcessingName

      public String getProcessingName(int priority)
      Parameters:
      priority - input priority.
      Returns:
      Returns the rate name inside the metric.

    • getName

      public String getName()