Uses of Interface
org.apache.hadoop.yarn.server.resourcemanager.rmcontainer.RMContainer
Packages that use RMContainer
Package
Description
Package org.apache.hadoop.yarn.server.resourcemanager.metrics contains
classes related to publishing app/container events to ATS.
-
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.ahs
Methods in org.apache.hadoop.yarn.server.resourcemanager.ahs with parameters of type RMContainerModifier and TypeMethodDescriptionvoidRMApplicationHistoryWriter.containerFinished(RMContainer container) voidRMApplicationHistoryWriter.containerStarted(RMContainer container) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.metrics
Methods in org.apache.hadoop.yarn.server.resourcemanager.metrics with parameters of type RMContainerModifier and TypeMethodDescriptionvoidCombinedSystemMetricsPublisher.containerCreated(RMContainer container, long createdTime) voidNoOpSystemMetricPublisher.containerCreated(RMContainer container, long createdTime) voidSystemMetricsPublisher.containerCreated(RMContainer container, long createdTime) voidTimelineServiceV1Publisher.containerCreated(RMContainer container, long createdTime) voidTimelineServiceV2Publisher.containerCreated(RMContainer container, long createdTime) voidCombinedSystemMetricsPublisher.containerFinished(RMContainer container, long finishedTime) voidNoOpSystemMetricPublisher.containerFinished(RMContainer container, long finishedTime) voidSystemMetricsPublisher.containerFinished(RMContainer container, long finishedTime) voidTimelineServiceV1Publisher.containerFinished(RMContainer container, long finishedTime) voidTimelineServiceV2Publisher.containerFinished(RMContainer container, long finishedTime) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return RMContainerMethods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return types with arguments of type RMContainerModifier and TypeMethodDescriptionTempSchedulerNode.getRunningContainers()ProportionalCapacityPreemptionPolicy.getToPreemptContainers()Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> FifoCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed) Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> IntraQueueCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) abstract Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> PreemptionCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Get preemption candidates from computed resource sharing and already selected candidates.Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> QueuePriorityContainerCandidateSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> ReservedContainerCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with parameters of type RMContainerModifier and TypeMethodDescriptionprotected static voidCapacitySchedulerPreemptionUtils.addToPreemptMap(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> preemptMap, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> curCandidates, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, RMContainer containerToPreempt) static booleanCapacitySchedulerPreemptionUtils.isContainerAlreadySelected(RMContainer container, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates) voidTempSchedulerNode.setReservedContainer(RMContainer reservedContainer) booleanFifoIntraQueuePreemptionPlugin.skipContainerBasedOnIntraQueuePolicy(FiCaSchedulerApp app, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource usedResource, RMContainer c) static booleanCapacitySchedulerPreemptionUtils.tryPreemptContainerAndDeductResToObtain(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, CapacitySchedulerPreemptionContext context, Map<String, org.apache.hadoop.yarn.api.records.Resource> resourceToObtainByPartitions, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Resource clusterResource, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> preemptMap, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> curCandidates, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed, boolean conservativeDRF) Invoke this method to preempt container based on resToObtain.Method parameters in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with type arguments of type RMContainerModifier and TypeMethodDescriptionprotected static voidCapacitySchedulerPreemptionUtils.addToPreemptMap(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> preemptMap, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> curCandidates, org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, RMContainer containerToPreempt) voidFifoIntraQueuePreemptionPlugin.computeAppsIdealAllocation(org.apache.hadoop.yarn.api.records.Resource clusterResource, TempQueuePerPartition tq, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed, org.apache.hadoop.yarn.api.records.Resource queueReassignableResource, float maxAllowablePreemptLimit) static voidCapacitySchedulerPreemptionUtils.deductPreemptableResourcesBasedSelectedCandidates(CapacitySchedulerPreemptionContext context, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates) static booleanCapacitySchedulerPreemptionUtils.isContainerAlreadySelected(RMContainer container, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates) Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> FifoCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed) Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> IntraQueueCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) abstract Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> PreemptionCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Get preemption candidates from computed resource sharing and already selected candidates.Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> QueuePriorityContainerCandidateSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,Set<RMContainer>> ReservedContainerCandidatesSelector.selectCandidates(Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed) voidTempSchedulerNode.setRunningContainers(List<RMContainer> runningContainers) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt
Methods in org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt with parameters of type RMContainerModifier and TypeMethodDescriptionvoidRMAppAttemptMetrics.updatePreemptionInfo(org.apache.hadoop.yarn.api.records.Resource resource, RMContainer container) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.rmcontainer
Classes in org.apache.hadoop.yarn.server.resourcemanager.rmcontainer that implement RMContainerMethods in org.apache.hadoop.yarn.server.resourcemanager.rmcontainer with parameters of type RMContainer -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler
Fields in org.apache.hadoop.yarn.server.resourcemanager.scheduler with type parameters of type RMContainerModifier and TypeFieldDescriptionprotected Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.liveContainersprotected List<RMContainer>SchedulerApplicationAttempt.newlyAllocatedContainersprotected Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.newlyDecreasedContainersprotected Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.newlyDemotedContainersprotected Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.newlyIncreasedContainersprotected Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.newlyPromotedContainersprotected final Map<org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey,Map<org.apache.hadoop.yarn.api.records.NodeId, RMContainer>> SchedulerApplicationAttempt.reservedContainersprotected List<RMContainer>SchedulerApplicationAttempt.tempContainerToKillMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler that return RMContainerModifier and TypeMethodDescriptionstatic RMContainerSchedulerUtils.createOpportunisticRmContainer(RMContext rmContext, org.apache.hadoop.yarn.api.records.Container container, boolean isRemotelyAllocated) protected RMContainerSchedulerNode.getContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Get the container for the specified container ID.SchedulerNode.getReservedContainer()Get the reserved container in the node.AbstractYarnScheduler.getRMContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) SchedContainerChangeRequest.getRMContainer()SchedulerApplicationAttempt.getRMContainer(org.apache.hadoop.yarn.api.records.ContainerId id) YarnScheduler.getRMContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Get the container for the given containerId.SchedulerApplicationAttempt.reserve(SchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Container container) ContainerUpdateContext.swapContainer(RMContainer tempRMContainer, RMContainer existingRMContainer, org.apache.hadoop.yarn.api.records.ContainerUpdateType updateType) Swaps the existing RMContainer's and the temp RMContainers internal container references after adjusting the resources in each.Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler that return types with arguments of type RMContainerModifier and TypeMethodDescriptionSchedulerNode.getContainersToKill()Get the containers running on the node ordered by which to kill first.SchedulerNode.getCopiedListOfRunningContainers()Get the containers running on the node.protected List<RMContainer>SchedulerNode.getLaunchedContainers()Get the launched containers in the node.SchedulerApplicationAttempt.getLiveContainers()Get the live containers of the application.SchedulerAppReport.getLiveContainers()Get the list of live containersMap<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> SchedulerApplicationAttempt.getLiveContainersMap()SchedulerApplicationAttempt.getReservedContainers()Get the list of reserved containersSchedulerAppReport.getReservedContainers()Get the list of reserved containersSchedulerNode.getRunningContainersWithAMsAtTheEnd()Get the containers running on the node with AM containers at the end.Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type RMContainerModifier and TypeMethodDescriptionvoidSchedulerApplicationAttempt.addRMContainer(org.apache.hadoop.yarn.api.records.ContainerId id, RMContainer rmContainer) voidSchedulerApplicationAttempt.addToNewlyAllocatedContainers(SchedulerNode node, RMContainer rmContainer) voidSchedulerApplicationAttempt.addToNewlyDecreasedContainers(org.apache.hadoop.yarn.api.records.ContainerId containerId, RMContainer rmContainer) voidSchedulerApplicationAttempt.addToNewlyDemotedContainers(org.apache.hadoop.yarn.api.records.ContainerId containerId, RMContainer rmContainer) AppSchedulingInfo.allocate(NodeType type, SchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer containerAllocated) voidSchedulerNode.allocateContainer(RMContainer rmContainer) The Scheduler has allocated containers on this node to the given application.protected voidSchedulerNode.allocateContainer(RMContainer rmContainer, boolean launchedOnNode) The Scheduler has allocated containers on this node to the given application.voidAbstractYarnScheduler.asyncContainerRelease(RMContainer container) To be used to release a container via a Scheduler Event rather than in the same thread.booleanContainerUpdateContext.checkAndAddToOutstandingIncreases(RMContainer rmContainer, SchedulerNode schedulerNode, org.apache.hadoop.yarn.api.records.UpdateContainerRequest updateRequest) Add the container to outstanding increases.voidAbstractYarnScheduler.completedContainer(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event) protected abstract voidAbstractYarnScheduler.completedContainerInternal(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event) abstract voidAbstractYarnScheduler.killContainer(RMContainer container) Kill a RMContainer.voidPreemptableResourceScheduler.killReservedContainer(RMContainer container) If the scheduler support container reservations, this method is used to ask the scheduler to drop the reservation for the given container.voidPreemptableResourceScheduler.markContainerForKillable(RMContainer container) Ask the scheduler to forcibly interrupt the container given as input.voidPreemptableResourceScheduler.markContainerForPreemption(org.apache.hadoop.yarn.api.records.ApplicationAttemptId aid, RMContainer container) Ask the scheduler to obtain back the container from a specific application by issuing a preemption requestorg.apache.hadoop.yarn.api.records.ContainerIdContainerUpdateContext.matchContainerToOutstandingIncreaseReq(SchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer rmContainer) Check if a new container is to be matched up against an outstanding Container increase request.voidAppSchedulingInfo.recoverContainer(RMContainer rmContainer, String partition) voidQueue.recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt schedulerAttempt, RMContainer rmContainer) Recover the state of the queue for a given container.booleanSchedulerApplicationAttempt.recoverContainer(SchedulerNode node, RMContainer rmContainer) voidSchedulerNode.recoverContainer(RMContainer rmContainer) Recover a container.SchedulerApplicationAttempt.reserve(SchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Container container) booleanSchedulerApplicationAttempt.reserveIncreasedContainer(SchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Resource reservedResource) abstract voidSchedulerNode.reserveResource(SchedulerApplicationAttempt attempt, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, RMContainer container) Reserve container for the attempt on this node.voidSchedulerNode.setReservedContainer(RMContainer reservedContainer) Set the reserved container in the node.ContainerUpdateContext.swapContainer(RMContainer tempRMContainer, RMContainer existingRMContainer, org.apache.hadoop.yarn.api.records.ContainerUpdateType updateType) Swaps the existing RMContainer's and the temp RMContainers internal container references after adjusting the resources in each.static voidAppSchedulingInfo.updateMetrics(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, NodeType type, SchedulerNode node, RMContainer containerAllocated, String user, Queue queue) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type RMContainerModifierConstructorDescriptionSchedContainerChangeRequest(RMContext rmContext, SchedulerNode schedulerNode, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Resource targetCapacity) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities with parameters of type RMContainerModifier and TypeMethodDescriptionstatic voidActivitiesLogger.APP.recordAppActivityWithAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, RMContainer updatedContainer, ActivityState activityState) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return RMContainerModifier and TypeMethodDescriptionCSAssignment.getExcessReservation()CSAssignment.getFulfilledReservedContainer()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return types with arguments of type RMContainerModifier and TypeMethodDescriptionCSAssignment.getContainersToKill()AbstractLeafQueue.getIgnoreExclusivityRMContainers()AbstractCSQueue.getKillableContainers(String partition) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type RMContainerModifier 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 queuevoidAbstractLeafQueue.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.protected voidCapacityScheduler.completedContainerInternal(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event) 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 queuevoidCapacityScheduler.killContainer(RMContainer container) voidCapacityScheduler.killReservedContainer(RMContainer container) voidCapacityScheduler.markContainerForKillable(RMContainer killableContainer) voidCapacityScheduler.markContainerForPreemption(org.apache.hadoop.yarn.api.records.ApplicationAttemptId aid, RMContainer cont) booleanCapacityScheduler.moveReservedContainer(RMContainer toBeMovedContainer, FiCaSchedulerNode targetNode) Try to move a reserved container to a targetNode.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) voidCSAssignment.setExcessReservation(RMContainer rmContainer) voidCSAssignment.setFulfilledReservedContainer(RMContainer fulfilledReservedContainer) Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with type arguments of type RMContainerModifier and TypeMethodDescriptionvoidCSAssignment.setContainersToKill(List<RMContainer> containersToKill) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type RMContainerModifierConstructorDescriptionCSAssignment(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 RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator that return RMContainerModifier and TypeMethodDescriptionContainerAllocation.getContainerToBeUnreserved()ContainerAllocation.getUpdatedContainer()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator that return types with arguments of type RMContainerMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator with parameters of type RMContainerModifier and TypeMethodDescriptionabstract CSAssignmentAbstractContainerAllocator.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, SchedulingMode schedulingMode, ResourceLimits resourceLimits, RMContainer reservedContainer) allocate needs to handle following stuffs: Select request: Select a request to allocate.ContainerAllocator.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, SchedulingMode schedulingMode, ResourceLimits resourceLimits, RMContainer reservedContainer) RegularContainerAllocator.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, SchedulingMode schedulingMode, ResourceLimits resourceLimits, RMContainer reservedContainer) protected CSAssignmentAbstractContainerAllocator.getCSAssignmentFromAllocateResult(org.apache.hadoop.yarn.api.records.Resource clusterResource, ContainerAllocation result, RMContainer rmContainer, FiCaSchedulerNode node) Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator with type arguments of type RMContainerModifier and TypeMethodDescriptionvoidContainerAllocation.setToKillContainers(List<RMContainer> toKillContainers) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator with parameters of type RMContainerModifierConstructorDescriptionContainerAllocation(RMContainer containerToBeUnreserved, org.apache.hadoop.yarn.api.records.Resource resourceToBeAllocated, AllocationState state) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.preemption
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.preemption that return RMContainerMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.preemption that return types with arguments of type RMContainerModifier and TypeMethodDescriptionMap<String,Map<org.apache.hadoop.yarn.api.records.ContainerId, RMContainer>> PreemptableQueue.getKillableContainers()PreemptionManager.getKillableContainers(String queueName, String partition) Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> PreemptionManager.getKillableContainersMap(String queueName, String partition) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.preemption with parameters of type RMContainerModifierConstructorDescriptionKillableContainer(RMContainer container, String partition, String leafQueueName) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common
Fields in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common declared as RMContainerMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common that return RMContainerModifier and TypeMethodDescriptionAssignmentInformation.getFirstAllocatedOrReservedRMContainer()SchedulerContainer.getRmContainer()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common with parameters of type RMContainerModifier and TypeMethodDescriptionvoidAssignmentInformation.addAllocationDetails(RMContainer rmContainer, String queue) voidAssignmentInformation.addReservationDetails(RMContainer rmContainer, String queue) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common with parameters of type RMContainerModifierConstructorDescriptionAssignmentDetails(RMContainer rmContainer, String queue) SchedulerContainer(A app, N node, RMContainer rmContainer, String nodePartition, boolean allocated) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica that return RMContainerModifier and TypeMethodDescriptionFiCaSchedulerApp.allocate(FiCaSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.Container container) FiCaSchedulerApp.findNodeToUnreserve(FiCaSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.Resource minimumUnreservedResource) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica that return types with arguments of type RMContainerModifier and TypeMethodDescriptionMap<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> FiCaSchedulerNode.getKillableContainers()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with parameters of type RMContainerModifier and TypeMethodDescriptionprotected voidFiCaSchedulerNode.allocateContainer(RMContainer rmContainer, boolean launchedOnNode) FiCaSchedulerApp.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> ps, ResourceLimits currentResourceLimits, SchedulingMode schedulingMode, RMContainer reservedContainer) booleanFiCaSchedulerApp.containerCompleted(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event, String partition) booleanFiCaSchedulerApp.moveReservation(RMContainer reservedContainer, FiCaSchedulerNode sourceNode, FiCaSchedulerNode targetNode) Move reservation from one node to another Comparing to unreserve container on source node and reserve a new container on target node.voidFiCaSchedulerApp.nodePartitionUpdated(RMContainer rmContainer, String oldPartition, String newPartition) voidFiCaSchedulerApp.reserve(org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, FiCaSchedulerNode node, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Container container, boolean reReservation) voidFiCaSchedulerNode.reserveResource(SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey priority, RMContainer container) booleanFiCaSchedulerApp.unreserve(org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, FiCaSchedulerNode node, RMContainer rmContainer) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event that return RMContainerModifier and TypeMethodDescriptionContainerPreemptEvent.getContainer()ReleaseContainerEvent.getContainer()Get RMContainer.Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event with parameters of type RMContainerModifierConstructorDescriptionContainerPreemptEvent(org.apache.hadoop.yarn.api.records.ApplicationAttemptId aid, RMContainer container, SchedulerEventType type) ReleaseContainerEvent(RMContainer rmContainer) Create Event. -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair that return RMContainerModifier and TypeMethodDescriptionFSAppAttempt.allocate(NodeType type, FSSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, PendingAsk pendingAsk, org.apache.hadoop.yarn.api.records.Container reservedContainer) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair with parameters of type RMContainerModifier and TypeMethodDescriptionprotected voidFSSchedulerNode.allocateContainer(RMContainer rmContainer, boolean launchedOnNode) The Scheduler has allocated containers on this node to the given application.protected voidFairScheduler.completedContainerInternal(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event) Clean up a completed container.voidFairScheduler.killContainer(RMContainer container) booleanFSAppAttempt.recoverContainer(SchedulerNode node, RMContainer rmContainer) voidFSLeafQueue.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) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo that return RMContainerModifier and TypeMethodDescriptionFifoAppAttempt.allocate(NodeType type, FiCaSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.Container container) FifoScheduler.getRMContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo with parameters of type RMContainerModifier and TypeMethodDescriptionprotected voidFifoScheduler.completedContainerInternal(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event) voidFifoScheduler.killContainer(RMContainer container) -
Uses of RMContainer in org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy with parameters of type RMContainerModifier and TypeMethodDescriptionabstract voidAbstractComparatorOrderingPolicy.containerAllocated(S schedulableEntity, RMContainer r) voidFairOrderingPolicy.containerAllocated(S schedulableEntity, RMContainer r) voidFifoOrderingPolicy.containerAllocated(S schedulableEntity, RMContainer r) voidFifoOrderingPolicyForPendingApps.containerAllocated(S schedulableEntity, RMContainer r) voidFifoOrderingPolicyWithExclusivePartitions.containerAllocated(S schedulableEntity, RMContainer r) voidOrderingPolicy.containerAllocated(S schedulableEntity, RMContainer r) Notify theOrderingPolicythat theSchedulableEntityhas been allocated the givenRMContainer, enabling theOrderingPolicyto take appropriate action.abstract voidAbstractComparatorOrderingPolicy.containerReleased(S schedulableEntity, RMContainer r) voidFairOrderingPolicy.containerReleased(S schedulableEntity, RMContainer r) voidFifoOrderingPolicy.containerReleased(S schedulableEntity, RMContainer r) voidFifoOrderingPolicyForPendingApps.containerReleased(S schedulableEntity, RMContainer r) voidFifoOrderingPolicyWithExclusivePartitions.containerReleased(S schedulableEntity, RMContainer r) voidOrderingPolicy.containerReleased(S schedulableEntity, RMContainer r) Notify theOrderingPolicythat theSchedulableEntityhas released the givenRMContainer, enabling theOrderingPolicyto take appropriate action.