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

Class QueueMetricsForCustomResources

java.lang.Object

org.apache.hadoop.yarn.metrics.CustomResourceMetrics

org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetricsForCustomResources

Direct Known Subclasses:

CSQueueMetricsForCustomResources

public class QueueMetricsForCustomResources
extends org.apache.hadoop.yarn.metrics.CustomResourceMetrics

Constructor Summary

Constructors

Constructor	Description
QueueMetricsForCustomResources()

Method Summary

Modifier and Type	Method	Description
void	decreasePending(org.apache.hadoop.yarn.api.records.Resource res)
void	decreasePending(org.apache.hadoop.yarn.api.records.Resource res, int containers)
void	decreaseReserved(org.apache.hadoop.yarn.api.records.Resource res)
Map<String,Long>	getPendingValues()
Map<String,Long>	getReservedValues()
void	increaseAggregatedPreempted(org.apache.hadoop.yarn.api.records.Resource res)
void	increaseAggregatedPreemptedSeconds(org.apache.hadoop.yarn.api.records.Resource res, long seconds)
void	increasePending(org.apache.hadoop.yarn.api.records.Resource res, int containers)
void	increaseReserved(org.apache.hadoop.yarn.api.records.Resource res)

Methods inherited from class org.apache.hadoop.yarn.metrics.CustomResourceMetrics

decreaseAllocated, decreaseAllocated, getAllocatedValues, getAvailable, getAvailableValues, increaseAllocated, increaseAllocated, initAndGetCustomResources, registerCustomResources, registerCustomResources, setAvailable

Methods inherited from class java.lang.Object

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

Constructor Details

QueueMetricsForCustomResources

public QueueMetricsForCustomResources()

Method Details

increaseReserved

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

decreaseReserved

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

increasePending

public void increasePending(org.apache.hadoop.yarn.api.records.Resource res,
 int containers)

decreasePending

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

decreasePending

public void decreasePending(org.apache.hadoop.yarn.api.records.Resource res,
 int containers)

getPendingValues

public Map<String,Long> getPendingValues()

getReservedValues

public Map<String,Long> getReservedValues()

increaseAggregatedPreemptedSeconds

public void increaseAggregatedPreemptedSeconds(org.apache.hadoop.yarn.api.records.Resource res,
 long seconds)

increaseAggregatedPreempted

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