Uses of Class
org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerNode
Packages that use FiCaSchedulerNode
Package
Description
-
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with parameters of type FiCaSchedulerNodeModifier and TypeMethodDescriptionstatic TempSchedulerNodeTempSchedulerNode.fromSchedulerNode(FiCaSchedulerNode schedulerNode) -
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities with parameters of type FiCaSchedulerNodeModifier and TypeMethodDescriptionstatic voidActivitiesLogger.APP.startAppAllocationRecording(ActivitiesManager activitiesManager, FiCaSchedulerNode node, long currentTime, SchedulerApplicationAttempt application) -
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return FiCaSchedulerNodeModifier and TypeMethodDescriptionCapacityScheduler.getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) CapacitySchedulerContext.getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) CapacitySchedulerQueueContext.getNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that return types with arguments of type FiCaSchedulerNodeModifier and TypeMethodDescriptionCapacityScheduler.createResourceCommitRequest(CSAssignment csAssignment) CapacityScheduler.getAllNodes()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type FiCaSchedulerNodeModifier and TypeMethodDescriptionAbstractCSQueue.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerNode node, ResourceLimits resourceLimits, SchedulingMode schedulingMode) CSQueue.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, FiCaSchedulerNode node, ResourceLimits resourceLimits, SchedulingMode schedulingMode) 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.booleanCapacityScheduler.moveReservedContainer(RMContainer toBeMovedContainer, FiCaSchedulerNode targetNode) Try to move a reserved container to a targetNode.static booleanCapacityScheduler.shouldSkipNodeSchedule(FiCaSchedulerNode node, CapacityScheduler cs, boolean printVerboseLog) Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with type arguments of type FiCaSchedulerNodeModifier 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) voidCapacityScheduler.addNodes(List<FiCaSchedulerNode> nodesToAdd) Add node to nodeTracker.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) AbstractLeafQueue.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, ResourceLimits currentResourceLimits, SchedulingMode schedulingMode) AbstractParentQueue.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, ResourceLimits resourceLimits, SchedulingMode schedulingMode) CSQueue.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> candidates, ResourceLimits resourceLimits, SchedulingMode schedulingMode) Assign containers to applications in the queue or it's children (if any). -
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.allocator with parameters of type FiCaSchedulerNodeModifier and TypeMethodDescriptionprotected 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 FiCaSchedulerNodeModifier 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) -
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica that return types with arguments of type FiCaSchedulerNodeModifier and TypeMethodDescriptionFiCaSchedulerApp.getAppPlacementAllocator(org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerRequestKey) Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with parameters of type FiCaSchedulerNodeModifier 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) 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.reserve(org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, FiCaSchedulerNode node, RMContainer rmContainer, org.apache.hadoop.yarn.api.records.Container container, boolean reReservation) booleanFiCaSchedulerApp.unreserve(org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, FiCaSchedulerNode node, RMContainer rmContainer) voidFiCaSchedulerApp.updateNodeInfoForAMDiagnostics(FiCaSchedulerNode node) Method parameters in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with type arguments of type FiCaSchedulerNodeModifier 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) FiCaSchedulerApp.assignContainers(org.apache.hadoop.yarn.api.records.Resource clusterResource, CandidateNodeSet<FiCaSchedulerNode> ps, ResourceLimits currentResourceLimits, SchedulingMode schedulingMode, RMContainer reservedContainer) -
Uses of FiCaSchedulerNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo with parameters of type FiCaSchedulerNodeModifier and TypeMethodDescriptionFifoAppAttempt.allocate(NodeType type, FiCaSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.Container container)