Uses of Class
org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplicationAttempt
Packages that use SchedulerApplicationAttempt
Package
Description
-
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler
Classes in org.apache.hadoop.yarn.server.resourcemanager.scheduler with type parameters of type SchedulerApplicationAttemptModifier and TypeClassDescriptionclassAbstractYarnScheduler<T extends SchedulerApplicationAttempt,N extends SchedulerNode> classSchedulerApplication<T extends SchedulerApplicationAttempt>Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type SchedulerApplicationAttemptModifier and TypeMethodDescriptionbooleanAbstractYarnScheduler.attemptAllocationOnNode(SchedulerApplicationAttempt appAttempt, org.apache.hadoop.yarn.api.records.SchedulingRequest schedulingRequest, SchedulerNode schedulerNode) Default implementation.booleanResourceScheduler.attemptAllocationOnNode(SchedulerApplicationAttempt appAttempt, org.apache.hadoop.yarn.api.records.SchedulingRequest schedulingRequest, SchedulerNode schedulerNode) Attempts to allocate a SchedulerRequest on a Node.protected voidAbstractYarnScheduler.autoCorrectContainerAllocation(List<org.apache.hadoop.yarn.api.records.ResourceRequest> resourceRequests, SchedulerApplicationAttempt application) Autocorrect container resourceRequests by decrementing the number of newly allocated containers from the current container request.AbstractYarnScheduler.getBlacklistedNodes(SchedulerApplicationAttempt app) Add blacklisted NodeIds to the list that is passed.protected voidAbstractYarnScheduler.handleContainerUpdates(SchedulerApplicationAttempt appAttempt, ContainerUpdates updates) static booleanSchedulerAppUtils.isPlaceBlacklisted(SchedulerApplicationAttempt application, SchedulerNode node, org.slf4j.Logger log) voidQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt schedulerAttempt, RMContainer rmContainer) Recover the state of the queue for a given container.protected voidAbstractYarnScheduler.releaseContainers(List<org.apache.hadoop.yarn.api.records.ContainerId> containers, SchedulerApplicationAttempt attempt) abstract voidSchedulerNode.reserveResource(SchedulerApplicationAttempt attempt, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer container) Reserve container for the attempt on this node.voidSchedulerApplicationAttempt.transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt) abstract voidSchedulerNode.unreserveResource(SchedulerApplicationAttempt attempt) Unreserve resources on this node.Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type SchedulerApplicationAttempt -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities with parameters of type SchedulerApplicationAttemptModifier and TypeMethodDescriptionstatic voidActivitiesLogger.APP.recordAppActivityWithAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, RMContainer updatedContainer, ActivityState activityState) static voidActivitiesLogger.APP.recordAppActivityWithoutAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, String diagnostic, ActivityState appState, ActivityLevel level) static voidActivitiesLogger.APP.recordRejectedAppActivityFromLeafQueue(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.api.records.Priority priority, String diagnostic) static voidActivitiesLogger.APP.recordSkippedAppActivityWithoutAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey requestKey, String diagnostic, ActivityLevel level) static voidActivitiesLogger.APP.startAppAllocationRecording(ActivitiesManager activitiesManager, FiCaSchedulerNode node, long currentTime, SchedulerApplicationAttempt application) -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type SchedulerApplicationAttemptModifier and TypeMethodDescriptionbooleanCapacityScheduler.attemptAllocationOnNode(SchedulerApplicationAttempt appAttempt, org.apache.hadoop.yarn.api.records.SchedulingRequest schedulingRequest, SchedulerNode schedulerNode) voidAbstractLeafQueue.decAMUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToDec, SchedulerApplicationAttempt application) voidAbstractCSQueue.decUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToDec, SchedulerApplicationAttempt application) voidAbstractLeafQueue.decUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToDec, SchedulerApplicationAttempt application) voidCSQueue.decUsedResource(String nodePartition, org.apache.hadoop.yarn.api.records.Resource resourceToDec, SchedulerApplicationAttempt application) When partition of node updated, we will update queue's resource usage if it has container(s) running on that.voidAbstractLeafQueue.incAMUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToInc, SchedulerApplicationAttempt application) voidAbstractCSQueue.incUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToInc, SchedulerApplicationAttempt application) voidAbstractLeafQueue.incUsedResource(String nodeLabel, org.apache.hadoop.yarn.api.records.Resource resourceToInc, SchedulerApplicationAttempt application) voidCSQueue.incUsedResource(String nodePartition, org.apache.hadoop.yarn.api.records.Resource resourceToInc, SchedulerApplicationAttempt application) When partition of node updated, we will update queue's resource usage if it has container(s) running on that.voidAbstractLeafQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt attempt, RMContainer rmContainer) voidAbstractParentQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt attempt, RMContainer rmContainer) -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common
Classes in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common with type parameters of type SchedulerApplicationAttemptModifier and TypeClassDescriptionclassContainerAllocationProposal<A extends SchedulerApplicationAttempt,N extends SchedulerNode> Proposal to allocate/reserve a new containerclassResourceCommitRequest<A extends SchedulerApplicationAttempt,N extends SchedulerNode> classSchedulerContainer<A extends SchedulerApplicationAttempt,N extends SchedulerNode> Contexts for a container inside scheduler -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Subclasses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.ficaModifier and TypeClassDescriptionclassRepresents an application attempt from the viewpoint of the FIFO or Capacity scheduler.Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with parameters of type SchedulerApplicationAttemptModifier and TypeMethodDescriptionvoidFiCaSchedulerNode.reserveResource(SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey priority, RMContainer container) voidFiCaSchedulerApp.transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt) voidFiCaSchedulerNode.unreserveResource(SchedulerApplicationAttempt application) -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair
Subclasses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fairModifier and TypeClassDescriptionclassRepresents an application attempt from the viewpoint of the Fair Scheduler.Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair with parameters of type SchedulerApplicationAttemptModifier and TypeMethodDescriptionvoidFSLeafQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt schedulerAttempt, RMContainer rmContainer) voidFSParentQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt schedulerAttempt, RMContainer rmContainer) voidFSSchedulerNode.reserveResource(SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer container) voidFSSchedulerNode.unreserveResource(SchedulerApplicationAttempt application) -
Uses of SchedulerApplicationAttempt in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo