Package org.apache.hadoop.yarn.server.resourcemanager

Class ClusterMetrics

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.ClusterMetrics
@Private @Metrics(context="yarn") public class ClusterMetrics extends Object

  • Method Details

    • getMetrics

      public static ClusterMetrics getMetrics()

    • destroy

      @VisibleForTesting public static void destroy()

    • setRmEventProcMonitorEnable

      public void setRmEventProcMonitorEnable(boolean value)

    • getRmEventProcMonitorEnable

      public boolean getRmEventProcMonitorEnable()

    • getRmEventProcCPUAvg

      public long getRmEventProcCPUAvg()

    • setRmEventProcCPUAvg

      public void setRmEventProcCPUAvg(long value)

    • getRmEventProcCPUMax

      public long getRmEventProcCPUMax()

    • setRmEventProcCPUMax

      public void setRmEventProcCPUMax(long value)

    • getNumActiveNMs

      public int getNumActiveNMs()

    • getNumDecommissioningNMs

      public int getNumDecommissioningNMs()

    • incrDecommissioningNMs

      public void incrDecommissioningNMs()

    • setDecommissioningNMs

      public void setDecommissioningNMs(int num)

    • decrDecommissioningNMs

      public void decrDecommissioningNMs()

    • getNumDecommisionedNMs

      public int getNumDecommisionedNMs()

    • incrDecommisionedNMs

      public void incrDecommisionedNMs()

    • setDecommisionedNMs

      public void setDecommisionedNMs(int num)

    • decrDecommisionedNMs

      public void decrDecommisionedNMs()

    • getNumLostNMs

      public int getNumLostNMs()

    • incrNumLostNMs

      public void incrNumLostNMs()

    • decrNumLostNMs

      public void decrNumLostNMs()

    • getUnhealthyNMs

      public int getUnhealthyNMs()

    • incrNumUnhealthyNMs

      public void incrNumUnhealthyNMs()

    • decrNumUnhealthyNMs

      public void decrNumUnhealthyNMs()

    • getNumRebootedNMs

      public int getNumRebootedNMs()

    • incrNumRebootedNMs

      public void incrNumRebootedNMs()

    • decrNumRebootedNMs

      public void decrNumRebootedNMs()

    • getNumShutdownNMs

      public int getNumShutdownNMs()

    • incrNumShutdownNMs

      public void incrNumShutdownNMs()

    • decrNumShutdownNMs

      public void decrNumShutdownNMs()

    • incrNumActiveNodes

      public void incrNumActiveNodes()

    • decrNumActiveNodes

      public void decrNumActiveNodes()

    • addAMLaunchDelay

      public void addAMLaunchDelay(long delay)

    • addAMRegisterDelay

      public void addAMRegisterDelay(long delay)

    • getCapabilityMB

      public long getCapabilityMB()

    • getCapabilityVirtualCores

      public long getCapabilityVirtualCores()

    • getCustomResourceCapability

      public Map<String,Long> getCustomResourceCapability()

    • setCustomResourceCapability

      public void setCustomResourceCapability(org.apache.hadoop.yarn.api.records.Resource res)

    • incrCapability

      public void incrCapability(org.apache.hadoop.yarn.api.records.Resource res)

    • decrCapability

      public void decrCapability(org.apache.hadoop.yarn.api.records.Resource res)

    • addAMContainerAllocationDelay

      public void addAMContainerAllocationDelay(long delay)

    • getAMContainerAllocationDelay

      public org.apache.hadoop.metrics2.lib.MutableRate getAMContainerAllocationDelay()

    • getUtilizedMB

      public long getUtilizedMB()

    • incrUtilizedMB

      public void incrUtilizedMB(long delta)

    • decrUtilizedMB

      public void decrUtilizedMB(long delta)

    • decrUtilizedVirtualCores

      public void decrUtilizedVirtualCores(long delta)

    • getUtilizedVirtualCores

      public long getUtilizedVirtualCores()

    • incrUtilizedVirtualCores

      public void incrUtilizedVirtualCores(long delta)

    • getContainerAssignedPerSecond

      public int getContainerAssignedPerSecond()

    • incrNumContainerAssigned

      public void incrNumContainerAssigned()

    • getRmEventQueueSize

      public int getRmEventQueueSize()

    • setRmEventQueueSize

      public void setRmEventQueueSize(int rmEventQueueSize)

    • getSchedulerEventQueueSize

      public int getSchedulerEventQueueSize()

    • setSchedulerEventQueueSize

      public void setSchedulerEventQueueSize(int schedulerEventQueueSize)