Constructor and Description |
---|
LeafQueue.User(String name) |
Modifier and Type | Method and Description |
---|---|
void |
activateApplication() |
void |
assignContainer(org.apache.hadoop.yarn.api.records.Resource resource,
String nodePartition) |
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() |
void |
releaseContainer(org.apache.hadoop.yarn.api.records.Resource resource,
String nodePartition) |
float |
resetAndUpdateUsageRatio(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) |
public LeafQueue.User(String name)
public ResourceUsage getResourceUsage()
public float resetAndUpdateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)
public float updateUsageRatio(org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)
public org.apache.hadoop.yarn.api.records.Resource getUsed()
public org.apache.hadoop.yarn.api.records.Resource getAllUsed()
public org.apache.hadoop.yarn.api.records.Resource getUsed(String label)
public int getPendingApplications()
public int getActiveApplications()
public org.apache.hadoop.yarn.api.records.Resource getConsumedAMResources()
public org.apache.hadoop.yarn.api.records.Resource getConsumedAMResources(String label)
public int getTotalApplications()
public void submitApplication()
public void activateApplication()
public void finishApplication(boolean wasActive)
public void assignContainer(org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)
public void releaseContainer(org.apache.hadoop.yarn.api.records.Resource resource, String nodePartition)
public org.apache.hadoop.yarn.api.records.Resource getUserResourceLimit()
public void setUserResourceLimit(org.apache.hadoop.yarn.api.records.Resource userResourceLimit)
public String getUserName()
public void setResourceUsage(ResourceUsage resourceUsage)
public float getWeight()
public void setWeight(float weight)
weight
- the weight to setCopyright © 2017 Apache Software Foundation. All Rights Reserved.