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

Interface CapacitySchedulerContext

All Known Implementing Classes:
CapacityScheduler
public interface CapacitySchedulerContext
Read-only interface to CapacityScheduler context.

  • Method Details

    • getConfiguration

      CapacitySchedulerConfiguration getConfiguration()

    • getQueueContext

      CapacitySchedulerQueueContext getQueueContext()

    • getMinimumResourceCapability

      org.apache.hadoop.yarn.api.records.Resource getMinimumResourceCapability()

    • getMaximumResourceCapability

      org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()

    • getMaximumResourceCapability

      org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability(String queueName)

    • getContainerTokenSecretManager

      RMContainerTokenSecretManager getContainerTokenSecretManager()

    • getNumClusterNodes

      int getNumClusterNodes()

    • getRMContext

      RMContext getRMContext()

    • getClusterResource

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

    • getConf

      org.apache.hadoop.conf.Configuration getConf()
      Get the yarn configuration.
      Returns:
      yarn configuration.

    • getResourceCalculator

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

    • getNode

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

    • getApplicationAttempt

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

    • getPreemptionManager

      PreemptionManager getPreemptionManager()

    • getSchedulerHealth

      SchedulerHealth getSchedulerHealth()

    • getLastNodeUpdateTime

      long getLastNodeUpdateTime()

    • getClusterResourceUsage

      ResourceUsage getClusterResourceUsage()
      Returns:
      QueueCapacities root queue of the Capacity Scheduler Queue, root queue used capacities for different labels are same as that of the cluster.

    • getActivitiesManager

      ActivitiesManager getActivitiesManager()

    • getCapacitySchedulerQueueManager

      CapacitySchedulerQueueManager getCapacitySchedulerQueueManager()

    • getMaxClusterLevelAppPriority

      org.apache.hadoop.yarn.api.records.Priority getMaxClusterLevelAppPriority()
      Returns:
      Max Cluster level App priority.

    • isConfigurationMutable

      boolean isConfigurationMutable()
      Returns if configuration is mutable.
      Returns:
      if configuration is mutable

    • getClock

      org.apache.hadoop.yarn.util.Clock getClock()
      Get clock from scheduler
      Returns:
      Clock

    • getPendingApplicationComparator

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