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

Methods

Modifier and Type	Method and 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()
String	getUser()
String	toString()

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

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

Methods inherited from class java.lang.Object

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

Method Detail

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)