@InterfaceAudience.Private @Metrics(context="yarn") public class ClusterMetrics extends Object
public static ClusterMetrics getMetrics()
@VisibleForTesting public static void destroy()
public void setRmEventProcMonitorEnable(boolean value)
public boolean getRmEventProcMonitorEnable()
public long getRmEventProcCPUAvg()
public void setRmEventProcCPUAvg(long value)
public long getRmEventProcCPUMax()
public void setRmEventProcCPUMax(long value)
public int getNumActiveNMs()
public int getNumDecommissioningNMs()
public void incrDecommissioningNMs()
public void setDecommissioningNMs(int num)
public void decrDecommissioningNMs()
public int getNumDecommisionedNMs()
public void incrDecommisionedNMs()
public void setDecommisionedNMs(int num)
public void decrDecommisionedNMs()
public int getNumLostNMs()
public void incrNumLostNMs()
public void decrNumLostNMs()
public int getUnhealthyNMs()
public void incrNumUnhealthyNMs()
public void decrNumUnhealthyNMs()
public int getNumRebootedNMs()
public void incrNumRebootedNMs()
public void decrNumRebootedNMs()
public int getNumShutdownNMs()
public void incrNumShutdownNMs()
public void decrNumShutdownNMs()
public void incrNumActiveNodes()
public void decrNumActiveNodes()
public void addAMLaunchDelay(long delay)
public void addAMRegisterDelay(long delay)
public long getCapabilityMB()
public long getCapabilityVirtualCores()
public void setCustomResourceCapability(org.apache.hadoop.yarn.api.records.Resource res)
public void incrCapability(org.apache.hadoop.yarn.api.records.Resource res)
public void decrCapability(org.apache.hadoop.yarn.api.records.Resource res)
public void addAMContainerAllocationDelay(long delay)
public org.apache.hadoop.metrics2.lib.MutableRate getAMContainerAllocationDelay()
public long getUtilizedMB()
public void incrUtilizedMB(long delta)
public void decrUtilizedMB(long delta)
public void decrUtilizedVirtualCores(long delta)
public long getUtilizedVirtualCores()
public void incrUtilizedVirtualCores(long delta)
public int getContainerAssignedPerSecond()
public void incrNumContainerAssigned()
public int getRmEventQueueSize()
public void setRmEventQueueSize(int rmEventQueueSize)
public int getSchedulerEventQueueSize()
public void setSchedulerEventQueueSize(int schedulerEventQueueSize)
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.