Uses of Interface
org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode
Packages that use RMNode
Package
Description
This package contains the web data access objects (DAO) for the RM.
-
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager
Methods in org.apache.hadoop.yarn.server.resourcemanager that return RMNodeMethods in org.apache.hadoop.yarn.server.resourcemanager that return types with arguments of type RMNodeModifier and TypeMethodDescriptionConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMActiveServiceContext.getInactiveRMNodes()ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMContext.getInactiveRMNodes()ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMContextImpl.getInactiveRMNodes()ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMActiveServiceContext.getRMNodes()ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMContext.getRMNodes()ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> RMContextImpl.getRMNodes()RMServerUtils.queryRMNodes(RMContext context, EnumSet<org.apache.hadoop.yarn.api.records.NodeState> acceptedStates) Methods in org.apache.hadoop.yarn.server.resourcemanager with parameters of type RMNodeModifier and TypeMethodDescriptionvoidClusterMonitor.addNode(List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerStatuses, RMNode rmNode) voidClusterMonitor.removeNode(RMNode removedRMNode) voidDecommissioningNodesWatcher.update(RMNode rmNode, org.apache.hadoop.yarn.server.api.records.NodeStatus remoteNodeStatus) Update rmNode decommissioning status based on NodeStatus.voidClusterMonitor.updateNode(RMNode rmNode) voidClusterMonitor.updateNodeResource(RMNode rmNode, org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) Constructors in org.apache.hadoop.yarn.server.resourcemanager with parameters of type RMNode -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.rmapp
Methods in org.apache.hadoop.yarn.server.resourcemanager.rmapp that return RMNodeMethod parameters in org.apache.hadoop.yarn.server.resourcemanager.rmapp with type arguments of type RMNodeModifier and TypeMethodDescriptionintRMApp.pullRMNodeUpdates(Map<RMNode, org.apache.hadoop.yarn.api.records.NodeUpdateType> updatedNodes) To receive the collection of allRMNodes whose updates have been received by the RMApp.intRMAppImpl.pullRMNodeUpdates(Map<RMNode, org.apache.hadoop.yarn.api.records.NodeUpdateType> upNodes) Constructors in org.apache.hadoop.yarn.server.resourcemanager.rmapp with parameters of type RMNodeModifierConstructorDescriptionRMAppNodeUpdateEvent(org.apache.hadoop.yarn.api.records.ApplicationId appId, RMNode node, RMAppNodeUpdateEvent.RMAppNodeUpdateType updateType) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.rmnode
Classes in org.apache.hadoop.yarn.server.resourcemanager.rmnode that implement RMNodeModifier and TypeClassDescriptionclassThis class is used to keep track of all the applications/containers running on a node.Methods in org.apache.hadoop.yarn.server.resourcemanager.rmnode that return RMNodeConstructors in org.apache.hadoop.yarn.server.resourcemanager.rmnode with parameters of type RMNodeModifierConstructorDescriptionRMNodeReconnectEvent(org.apache.hadoop.yarn.api.records.NodeId nodeId, RMNode newNode, List<org.apache.hadoop.yarn.api.records.ApplicationId> runningApps, List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerReports) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler that return RMNodeMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type RMNodeModifier and TypeMethodDescriptionprotected voidAbstractYarnScheduler.nodeUpdate(RMNode nm) Process a heartbeat update from a node.voidAbstractYarnScheduler.recoverContainersOnNode(List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerReports, RMNode nm) voidAbstractYarnScheduler.updateNodeResource(RMNode nm, org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) Process resource update on a node.protected voidAbstractYarnScheduler.updateNodeResourceUtilization(RMNode nm, SchedulerNode schedulerNode) Update container and utilization information on the NodeManager.Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type RMNodeModifierConstructorDescriptionSchedulerNode(RMNode node, boolean usePortForNodeName) SchedulerNode(RMNode node, boolean usePortForNodeName, Set<String> labels) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type RMNode -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with parameters of type RMNodeModifierConstructorDescriptionFiCaSchedulerNode(RMNode node, boolean usePortForNodeName) FiCaSchedulerNode(RMNode node, boolean usePortForNodeName, Set<String> nodeLabels) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.distributed
Fields in org.apache.hadoop.yarn.server.resourcemanager.scheduler.distributed with type parameters of type RMNodeMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.distributed that return RMNodeModifier and TypeMethodDescriptionNodeQueueLoadMonitor.selectAnyNode(Set<String> blacklist, org.apache.hadoop.yarn.api.records.Resource request) Selects a node from all ClusterNodes for resource allocation, excluding blacklisted nodes.NodeQueueLoadMonitor.selectLocalNode(String hostName, Set<String> blacklist, org.apache.hadoop.yarn.api.records.Resource request) Selects the node as specified by hostName for resource allocation, unless the node has been blacklisted.NodeQueueLoadMonitor.selectRackLocalNode(String rackName, Set<String> blacklist, org.apache.hadoop.yarn.api.records.Resource request) Selects a node from the rack as specified by rackName for resource allocation, excluding blacklisted nodesMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.distributed with parameters of type RMNodeModifier and TypeMethodDescriptionprotected voidNodeQueueLoadMonitor.addIntoNodeIdsByRack(RMNode addedNode) voidNodeQueueLoadMonitor.addNode(List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerStatuses, RMNode rmNode) protected voidNodeQueueLoadMonitor.onExistingNodeUpdated(RMNode rmNode, ClusterNode clusterNode, org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus status) protected voidNodeQueueLoadMonitor.onNewNodeAdded(RMNode rmNode, org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus status) protected voidNodeQueueLoadMonitor.removeFromNodeIdsByRack(RMNode removedNode) voidNodeQueueLoadMonitor.removeNode(RMNode removedRMNode) voidNodeQueueLoadMonitor.updateNode(RMNode rmNode) voidNodeQueueLoadMonitor.updateNodeResource(RMNode rmNode, org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event that return RMNodeModifier and TypeMethodDescriptionNodeAddedSchedulerEvent.getAddedRMNode()NodeRemovedSchedulerEvent.getRemovedRMNode()NodeResourceUpdateSchedulerEvent.getRMNode()NodeUpdateSchedulerEvent.getRMNode()Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.event with parameters of type RMNodeModifierConstructorDescriptionNodeAddedSchedulerEvent(RMNode rmNode) NodeAddedSchedulerEvent(RMNode rmNode, List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerReports) NodeRemovedSchedulerEvent(RMNode rmNode) NodeResourceUpdateSchedulerEvent(RMNode rmNode, org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) NodeUpdateSchedulerEvent(RMNode rmNode) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair with parameters of type RMNodeModifier and TypeMethodDescriptionprotected voidFairScheduler.nodeUpdate(RMNode nm) voidFairScheduler.updateNodeResource(RMNode nm, org.apache.hadoop.yarn.api.records.ResourceOption resourceOption) Process resource update on a node and update Queue.Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair with parameters of type RMNode -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo
Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo with parameters of type RMNodeModifier and TypeMethodDescriptionprotected voidFifoScheduler.nodeUpdate(RMNode nm) voidFifoScheduler.recoverContainersOnNode(List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerReports, RMNode nm) -
Uses of RMNode in org.apache.hadoop.yarn.server.resourcemanager.webapp.dao
Constructors in org.apache.hadoop.yarn.server.resourcemanager.webapp.dao with parameters of type RMNode