public interface CapacitySchedulerContext
CapacityScheduler
context.CapacitySchedulerConfiguration getConfiguration()
org.apache.hadoop.yarn.api.records.Resource getMinimumResourceCapability()
org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()
org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability(String queueName)
RMContainerTokenSecretManager getContainerTokenSecretManager()
int getNumClusterNodes()
RMContext getRMContext()
org.apache.hadoop.yarn.api.records.Resource getClusterResource()
org.apache.hadoop.conf.Configuration getConf()
org.apache.hadoop.yarn.util.resource.ResourceCalculator getResourceCalculator()
Comparator<CSQueue> getNonPartitionedQueueComparator()
PartitionedQueueComparator getPartitionedQueueComparator()
FiCaSchedulerNode getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
FiCaSchedulerApp getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
SchedulerHealth getSchedulerHealth()
ResourceUsage getClusterResourceUsage()
PreemptionManager getPreemptionManager()
long getLastNodeUpdateTime()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.