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

Class UsersManager.User

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.UsersManager.User

Enclosing class:

UsersManager

@VisibleForTesting
public static class UsersManager.User
extends Object

User class stores all user related resource usage, application details.

Constructor Summary

Constructors

Constructor	Description
User(String name)

Method Summary

Modifier and Type	Method	Description
void	activateApplication()
void	finishApplication(boolean wasActive)
int	getActiveApplications()
org.apache.hadoop.yarn.api.records.Resource	getAllUsed()
org.apache.hadoop.yarn.api.records.Resource	getConsumedAMResources()
org.apache.hadoop.yarn.api.records.Resource	getConsumedAMResources(String label)
int	getPendingApplications()
ResourceUsage	getResourceUsage()
int	getTotalApplications()
org.apache.hadoop.yarn.api.records.Resource	getUsed()
org.apache.hadoop.yarn.api.records.Resource	getUsed(String label)
String	getUserName()
org.apache.hadoop.yarn.api.records.Resource	getUserResourceLimit()
float	getWeight()
float	setAndUpdateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)
void	setResourceUsage(ResourceUsage resourceUsage)
void	setUserResourceLimit(org.apache.hadoop.yarn.api.records.Resource userResourceLimit)
void	setWeight(float weight)
void	submitApplication()
float	updateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)

Methods inherited from class java.lang.Object

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

Constructor Details

User

public User(String name)

Method Details

getResourceUsage

public ResourceUsage getResourceUsage()

setAndUpdateUsageRatio

public float setAndUpdateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
 org.apache.hadoop.yarn.api.records.Resource resource,
 String nodePartition)

updateUsageRatio

public float updateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
 org.apache.hadoop.yarn.api.records.Resource resource,
 String nodePartition)

getUsed

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

getAllUsed

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

getUsed

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

getPendingApplications

public int getPendingApplications()

getActiveApplications

public int getActiveApplications()

getConsumedAMResources

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

getConsumedAMResources

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

getTotalApplications

public int getTotalApplications()

submitApplication

public void submitApplication()

activateApplication

public void activateApplication()

finishApplication

public void finishApplication(boolean wasActive)

getUserResourceLimit

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

setUserResourceLimit

public void setUserResourceLimit(org.apache.hadoop.yarn.api.records.Resource userResourceLimit)

getUserName

public String getUserName()

setResourceUsage

@VisibleForTesting
public void setResourceUsage(ResourceUsage resourceUsage)

getWeight

public float getWeight()

Returns:

the weight

setWeight

public void setWeight(float weight)

Parameters:

weight - the weight to set