public class TempQueuePerPartition extends AbstractPreemptionEntity
amUsed, current, pending, reserved
Modifier and Type | Method and Description |
---|---|
void |
addAllApps(Collection<TempAppPerPartition> orderedApps) |
void |
addChild(TempQueuePerPartition q)
When adding a child we also aggregate its pending resource needs.
|
void |
addUserPerPartition(String userName,
TempUserPerPartition tmpUser) |
void |
assignPreemption(float scalingFactor,
org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.api.records.Resource clusterResource) |
void |
deductActuallyToBePreempted(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.api.records.Resource cluster,
org.apache.hadoop.yarn.api.records.Resource toBeDeduct) |
Collection<TempAppPerPartition> |
getApps() |
ArrayList<TempQueuePerPartition> |
getChildren() |
org.apache.hadoop.yarn.api.records.Resource |
getGuaranteed() |
org.apache.hadoop.yarn.api.records.Resource |
getMax() |
org.apache.hadoop.yarn.api.records.Resource |
getUsedDeductReservd() |
Map<String,TempUserPerPartition> |
getUsersPerPartition() |
void |
setLeafQueue(LeafQueue l) |
String |
toString() |
void |
updatePreemptableExtras(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc) |
getActuallyToBePreempted, getAMUsed, getPending, getReserved, getToBePreemptFromOther, getUsed, getUsedDeductAM, setActuallyToBePreempted, setToBePreemptFromOther
public void setLeafQueue(LeafQueue l)
public void addChild(TempQueuePerPartition q)
q
- the child queue to add to this queuepublic ArrayList<TempQueuePerPartition> getChildren()
public org.apache.hadoop.yarn.api.records.Resource getUsedDeductReservd()
public org.apache.hadoop.yarn.api.records.Resource getGuaranteed()
public org.apache.hadoop.yarn.api.records.Resource getMax()
public void updatePreemptableExtras(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc)
public void assignPreemption(float scalingFactor, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource clusterResource)
public void deductActuallyToBePreempted(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource cluster, org.apache.hadoop.yarn.api.records.Resource toBeDeduct)
public void addAllApps(Collection<TempAppPerPartition> orderedApps)
public Collection<TempAppPerPartition> getApps()
public void addUserPerPartition(String userName, TempUserPerPartition tmpUser)
public Map<String,TempUserPerPartition> getUsersPerPartition()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.