Uses of Class
org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerApp
Packages that use FiCaSchedulerApp
Package
Description
-
Uses of FiCaSchedulerApp in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return FiCaSchedulerAppMethods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return types with arguments of type FiCaSchedulerAppModifier and TypeMethodDescriptionFifoIntraQueuePreemptionPlugin.getPreemptableApps(String queueName, String partition) Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with parameters of type FiCaSchedulerAppModifier and TypeMethodDescriptionbooleanFifoIntraQueuePreemptionPlugin.skipContainerBasedOnIntraQueuePolicy(FiCaSchedulerApp app, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource usedResource, RMContainer c) -
Uses of FiCaSchedulerApp in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return FiCaSchedulerAppModifier and TypeMethodDescriptionCSAssignment.getApplication()CapacityScheduler.getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId) CapacitySchedulerContext.getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId) CapacitySchedulerQueueContext.getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return types with arguments of type FiCaSchedulerAppModifier and TypeMethodDescriptionCapacityScheduler.createResourceCommitRequest(CSAssignment csAssignment) AbstractLeafQueue.getAllApplications()Obtain (read-only) collection of all applications.ManagedParentQueue.getAllApplications()AbstractLeafQueue.getApplications()Obtain (read-only) collection of active applications.AbstractLeafQueue.getOrderingPolicy()AbstractLeafQueue.getPendingApplications()Obtain (read-only) collection of pending applications.ManagedParentQueue.getPendingApplications()AbstractLeafQueue.getPendingAppsOrderingPolicy()ManagedParentQueue.getScheduleableApplications()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type FiCaSchedulerAppModifier and TypeMethodDescriptionvoidAbstractLeafQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer rmContainer) voidAbstractParentQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer rmContainer) voidCSQueue.attachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer container) Attach a container to this queueprotected booleanAbstractLeafQueue.canAssignToUser(org.apache.hadoop.yarn.api.records.Resource clusterResource, String userName, org.apache.hadoop.yarn.api.records.Resource limit, FiCaSchedulerApp application, String nodePartition, ResourceLimits currentResourceLimits) booleanCSMaxRunningAppsEnforcer.checkRunnabilityWithUpdate(FiCaSchedulerApp attempt) Checks whether making the application runnable would exceed any maxRunningApps limits.voidAbstractLeafQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, FiCaSchedulerNode node, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event, CSQueue childQueue, boolean sortQueues) voidAbstractParentQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, FiCaSchedulerNode node, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event, CSQueue completedChildQueue, boolean sortQueues) voidCSQueue.completedContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, FiCaSchedulerNode node, RMContainer container, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event, CSQueue childQueue, boolean sortQueues) A container assigned to the queue has completed.voidAbstractLeafQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer rmContainer) voidAbstractParentQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer rmContainer) voidCSQueue.detachContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, RMContainer container) Detach a container from this queuevoidAbstractLeafQueue.finishApplicationAttempt(FiCaSchedulerApp application, String queue) voidAbstractParentQueue.finishApplicationAttempt(FiCaSchedulerApp application, String queue) voidCSQueue.finishApplicationAttempt(FiCaSchedulerApp application, String queue) An application attempt submitted to this queue has finished.protected org.apache.hadoop.yarn.api.records.ResourceAbstractLeafQueue.getHeadroom(UsersManager.User user, org.apache.hadoop.yarn.api.records.Resource queueCurrentLimit, org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application) protected org.apache.hadoop.yarn.api.records.ResourceAbstractLeafQueue.getHeadroom(UsersManager.User user, org.apache.hadoop.yarn.api.records.Resource queueCurrentLimit, org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerApp application, String partition) voidCSAssignment.setApplication(FiCaSchedulerApp application) voidAbstractLeafQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName) voidAbstractLeafQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName, boolean isMoveApp) voidAbstractParentQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName) voidAbstractParentQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName, boolean isMoveApp) voidCSQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName) Submit an application attempt to the queue.voidCSQueue.submitApplicationAttempt(FiCaSchedulerApp application, String userName, boolean isMoveApp) Submit an application attempt to the queue.voidCSMaxRunningAppsEnforcer.trackApp(FiCaSchedulerApp app) voidCSMaxRunningAppsEnforcer.untrackApp(FiCaSchedulerApp app) voidCSMaxRunningAppsEnforcer.updateRunnabilityOnAppRemoval(FiCaSchedulerApp app) Checks to see whether any other applications runnable now that the given application has been removed from the given queue.Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with type arguments of type FiCaSchedulerAppModifier and TypeMethodDescriptionbooleanAbstractCSQueue.accept(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) Checks whether this queue could accept the container allocation request.booleanAbstractLeafQueue.accept(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) booleanCSQueue.accept(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) voidAbstractLeafQueue.apply(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) voidAbstractParentQueue.apply(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) voidCSQueue.apply(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request) voidAbstractLeafQueue.updateApplicationPriority(SchedulerApplication<FiCaSchedulerApp> app, org.apache.hadoop.yarn.api.records.Priority newAppPriority) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type FiCaSchedulerAppModifierConstructorDescriptionCapacityHeadroomProvider(UsersManager.User user, AbstractLeafQueue queue, FiCaSchedulerApp application, org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractLeafQueue.QueueResourceLimitsInfo queueResourceLimitsInfo) CSAssignment(org.apache.hadoop.yarn.api.records.Resource resource, NodeType type, RMContainer excessReservation, FiCaSchedulerApp application, CSAssignment.SkippedType skipped, boolean fulfilledReservation) CSAssignment(FiCaSchedulerApp application, RMContainer excessReservation) -
Uses of FiCaSchedulerApp in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator
Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator with parameters of type FiCaSchedulerAppModifierConstructorDescriptionAbstractContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext) AbstractContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext, ActivitiesManager activitiesManager) ContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext) ContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext, ActivitiesManager activitiesManager) RegularContainerAllocator(FiCaSchedulerApp application, org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, RMContext rmContext, ActivitiesManager activitiesManager) -
Uses of FiCaSchedulerApp in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with type arguments of type FiCaSchedulerAppModifier and TypeMethodDescriptionbooleanFiCaSchedulerApp.accept(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request, boolean checkPending) booleanFiCaSchedulerApp.apply(org.apache.hadoop.yarn.api.records.Resource cluster, ResourceCommitRequest<FiCaSchedulerApp, FiCaSchedulerNode> request, boolean updatePending) -
Uses of FiCaSchedulerApp in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo