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

Class TempAppPerPartition

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity

org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempAppPerPartition

public class TempAppPerPartition
extends AbstractPreemptionEntity

Temporary data-structure tracking resource availability, pending resource need, current utilization for an application.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity

amUsed, current, pending, reserved

Method Summary

Modifier and Type	Method	Description
void	assignPreemption(org.apache.hadoop.yarn.api.records.Resource killable)
void	deductActuallyToBePreempted(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource cluster, org.apache.hadoop.yarn.api.records.Resource toBeDeduct)
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationId()
FiCaSchedulerApp	getFiCaSchedulerApp()
int	getPriority()
TempUserPerPartition	getTempUserPerPartition()
String	getUser()
void	setTempUserPerPartition(TempUserPerPartition tu)
String	toString()

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity

getActuallyToBePreempted, getAMUsed, getPending, getQueueName, getReserved, getToBePreemptFromOther, getUsed, getUsedDeductAM, setActuallyToBePreempted, setToBePreemptFromOther

Methods inherited from class java.lang.Object

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

Method Details

getFiCaSchedulerApp

public FiCaSchedulerApp getFiCaSchedulerApp()

assignPreemption

public void assignPreemption(org.apache.hadoop.yarn.api.records.Resource killable)

toString

public String toString()

Overrides:

toString in class Object

getPriority

public int getPriority()

getApplicationId

public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()

getUser

public String getUser()

deductActuallyToBePreempted

public void deductActuallyToBePreempted(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
 org.apache.hadoop.yarn.api.records.Resource cluster,
 org.apache.hadoop.yarn.api.records.Resource toBeDeduct)

setTempUserPerPartition

public void setTempUserPerPartition(TempUserPerPartition tu)

getTempUserPerPartition

public TempUserPerPartition getTempUserPerPartition()