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

Class CapacitySchedulerQueueContext

java.lang.Object

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

public class CapacitySchedulerQueueContext
extends Object

Class to store common queue related information, like instances to necessary manager classes or the global CapacityScheduler configuration.

Constructor Summary

Constructors

Constructor	Description
CapacitySchedulerQueueContext(CapacitySchedulerContext csContext)

Method Summary

Modifier and Type	Method	Description
ActivitiesManager	getActivitiesManager()
FiCaSchedulerApp	getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler.PendingApplicationComparator	getApplicationComparator()
org.apache.hadoop.yarn.api.records.Resource	getClusterResource()
ResourceUsage	getClusterResourceUsage()
CapacitySchedulerConfiguration	getConfiguration()
RMNodeLabelsManager	getLabelManager()
long	getLastNodeUpdateTime()
org.apache.hadoop.yarn.api.records.Resource	getMinimumAllocation()
FiCaSchedulerNode	getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
PreemptionManager	getPreemptionManager()
CapacitySchedulerQueueManager	getQueueManager()
org.apache.hadoop.yarn.util.resource.ResourceCalculator	getResourceCalculator()
SchedulerHealth	getSchedulerHealth()
void	reinitialize()
void	setConfigurationEntry(String name, String value)

Methods inherited from class java.lang.Object

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

Constructor Details

CapacitySchedulerQueueContext

public CapacitySchedulerQueueContext(CapacitySchedulerContext csContext)

Method Details

reinitialize

public void reinitialize()

getQueueManager

public CapacitySchedulerQueueManager getQueueManager()

getLabelManager

public RMNodeLabelsManager getLabelManager()

getPreemptionManager

public PreemptionManager getPreemptionManager()

getActivitiesManager

public ActivitiesManager getActivitiesManager()

getResourceCalculator

public org.apache.hadoop.yarn.util.resource.ResourceCalculator getResourceCalculator()

getConfiguration

public CapacitySchedulerConfiguration getConfiguration()

setConfigurationEntry

public void setConfigurationEntry(String name,
 String value)

getMinimumAllocation

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

getClusterResource

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

getClusterResourceUsage

public ResourceUsage getClusterResourceUsage()

getSchedulerHealth

public SchedulerHealth getSchedulerHealth()

getLastNodeUpdateTime

public long getLastNodeUpdateTime()

getNode

public FiCaSchedulerNode getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)

getApplicationAttempt

public FiCaSchedulerApp getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)

getApplicationComparator

public org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler.PendingApplicationComparator getApplicationComparator()