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

Class ResourceUsage

java.lang.Object

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

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

public class ResourceUsage
extends AbstractResourceUsage

Resource Usage by Labels for following fields by label - AM resource (to enforce max-am-resource-by-label after YARN-2637) - Used resource (includes AM resource usage) - Reserved resource - Pending resource - Headroom This class can be used to track resource usage in queue/user/app. And it is thread-safe

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.AbstractResourceUsage

AbstractResourceUsage.ResourceType, AbstractResourceUsage.UsageByLabel

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.AbstractResourceUsage

readLock, usages, writeLock

Constructor Summary

Constructors

Constructor	Description
ResourceUsage()

Method Summary

Modifier and Type	Method	Description
void	copyAllUsed(AbstractResourceUsage other)
void	decAMLimit(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	decAMLimit(org.apache.hadoop.yarn.api.records.Resource res)
void	decAMUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	decAMUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	decPending(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	decPending(org.apache.hadoop.yarn.api.records.Resource res)
void	decReserved(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	decReserved(org.apache.hadoop.yarn.api.records.Resource res)
void	decUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	decUsed(org.apache.hadoop.yarn.api.records.Resource res)
org.apache.hadoop.yarn.api.records.Resource	getAllPending()
org.apache.hadoop.yarn.api.records.Resource	getAllReserved()
org.apache.hadoop.yarn.api.records.Resource	getAllUsed()
org.apache.hadoop.yarn.api.records.Resource	getAMLimit()
org.apache.hadoop.yarn.api.records.Resource	getAMLimit(String label)
org.apache.hadoop.yarn.api.records.Resource	getAMUsed()
org.apache.hadoop.yarn.api.records.Resource	getAMUsed(String label)
org.apache.hadoop.yarn.api.records.Resource	getCachedDemand(String label)
org.apache.hadoop.yarn.api.records.Resource	getCachedPending()
org.apache.hadoop.yarn.api.records.Resource	getCachedPending(String label)
org.apache.hadoop.yarn.api.records.Resource	getCachedUsed()
org.apache.hadoop.yarn.api.records.Resource	getCachedUsed(String label)
org.apache.hadoop.yarn.api.records.Resource	getPending()
org.apache.hadoop.yarn.api.records.Resource	getPending(String label)
org.apache.hadoop.yarn.api.records.Resource	getReserved()
org.apache.hadoop.yarn.api.records.Resource	getReserved(String label)
org.apache.hadoop.yarn.api.records.Resource	getUsed()
org.apache.hadoop.yarn.api.records.Resource	getUsed(String label)
org.apache.hadoop.yarn.api.records.Resource	getUserAMLimit()
org.apache.hadoop.yarn.api.records.Resource	getUserAMLimit(String label)
void	incAMLimit(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	incAMLimit(org.apache.hadoop.yarn.api.records.Resource res)
void	incAMUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	incAMUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	incPending(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	incPending(org.apache.hadoop.yarn.api.records.Resource res)
void	incReserved(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	incReserved(org.apache.hadoop.yarn.api.records.Resource res)
void	incUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	incUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	setAMLimit(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setAMLimit(org.apache.hadoop.yarn.api.records.Resource res)
void	setAMUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setAMUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	setCachedPending(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setCachedPending(org.apache.hadoop.yarn.api.records.Resource res)
void	setCachedUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setCachedUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	setPending(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setPending(org.apache.hadoop.yarn.api.records.Resource res)
void	setReserved(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setReserved(org.apache.hadoop.yarn.api.records.Resource res)
void	setUsed(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setUsed(org.apache.hadoop.yarn.api.records.Resource res)
void	setUserAMLimit(String label, org.apache.hadoop.yarn.api.records.Resource res)
void	setUserAMLimit(org.apache.hadoop.yarn.api.records.Resource res)

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.AbstractResourceUsage

_dec, _get, _getAll, _inc, _set, getExistingNodeLabels, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ResourceUsage

public ResourceUsage()

Method Details

getUsed

public org.apache.hadoop.yarn.api.records.Resource getUsed()

getUsed

public org.apache.hadoop.yarn.api.records.Resource getUsed(String label)

incUsed

public void incUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

incUsed

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

decUsed

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

decUsed

public void decUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setUsed

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

copyAllUsed

public void copyAllUsed(AbstractResourceUsage other)

setUsed

public void setUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getPending

public org.apache.hadoop.yarn.api.records.Resource getPending()

getPending

public org.apache.hadoop.yarn.api.records.Resource getPending(String label)

incPending

public void incPending(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

incPending

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

decPending

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

decPending

public void decPending(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setPending

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

setPending

public void setPending(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getReserved

public org.apache.hadoop.yarn.api.records.Resource getReserved()

getReserved

public org.apache.hadoop.yarn.api.records.Resource getReserved(String label)

incReserved

public void incReserved(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

incReserved

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

decReserved

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

decReserved

public void decReserved(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setReserved

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

setReserved

public void setReserved(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getAMUsed

public org.apache.hadoop.yarn.api.records.Resource getAMUsed()

getAMUsed

public org.apache.hadoop.yarn.api.records.Resource getAMUsed(String label)

incAMUsed

public void incAMUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

incAMUsed

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

decAMUsed

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

decAMUsed

public void decAMUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setAMUsed

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

setAMUsed

public void setAMUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getAllPending

public org.apache.hadoop.yarn.api.records.Resource getAllPending()

getAllUsed

public org.apache.hadoop.yarn.api.records.Resource getAllUsed()

getAllReserved

public org.apache.hadoop.yarn.api.records.Resource getAllReserved()

getCachedUsed

public org.apache.hadoop.yarn.api.records.Resource getCachedUsed()

getCachedUsed

public org.apache.hadoop.yarn.api.records.Resource getCachedUsed(String label)

getCachedPending

public org.apache.hadoop.yarn.api.records.Resource getCachedPending()

getCachedPending

public org.apache.hadoop.yarn.api.records.Resource getCachedPending(String label)

setCachedUsed

public void setCachedUsed(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setCachedUsed

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

setCachedPending

public void setCachedPending(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setCachedPending

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

getAMLimit

public org.apache.hadoop.yarn.api.records.Resource getAMLimit()

getAMLimit

public org.apache.hadoop.yarn.api.records.Resource getAMLimit(String label)

incAMLimit

public void incAMLimit(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

incAMLimit

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

decAMLimit

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

decAMLimit

public void decAMLimit(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

setAMLimit

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

setAMLimit

public void setAMLimit(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getUserAMLimit

public org.apache.hadoop.yarn.api.records.Resource getUserAMLimit()

getUserAMLimit

public org.apache.hadoop.yarn.api.records.Resource getUserAMLimit(String label)

setUserAMLimit

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

setUserAMLimit

public void setUserAMLimit(String label,
 org.apache.hadoop.yarn.api.records.Resource res)

getCachedDemand

public org.apache.hadoop.yarn.api.records.Resource getCachedDemand(String label)