Modifier and Type | Method and Description |
---|---|
RMNode |
NodesListManagerEvent.getNode() |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,RMNode> |
RMContext.getInactiveRMNodes() |
ConcurrentMap<String,RMNode> |
RMActiveServiceContext.getInactiveRMNodes() |
ConcurrentMap<String,RMNode> |
RMContextImpl.getInactiveRMNodes() |
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> |
RMContext.getRMNodes() |
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> |
RMActiveServiceContext.getRMNodes() |
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> |
RMContextImpl.getRMNodes() |
static List<RMNode> |
RMServerUtils.queryRMNodes(RMContext context,
EnumSet<org.apache.hadoop.yarn.api.records.NodeState> acceptedStates) |
Modifier and Type | Method and Description |
---|---|
int |
NodesListManager.getUnusableNodes(Collection<RMNode> unUsableNodes)
Provides the currently unusable nodes.
|
Constructor and Description |
---|
NodesListManagerEvent(NodesListManagerEventType type,
RMNode node) |
Modifier and Type | Method and Description |
---|---|
RMNode |
RMAppNodeUpdateEvent.getNode() |
Modifier and Type | Method and Description |
---|---|
int |
RMApp.pullRMNodeUpdates(Collection<RMNode> updatedNodes)
To receive the collection of all
RMNode s whose updates have been
received by the RMApp. |
int |
RMAppImpl.pullRMNodeUpdates(Collection<RMNode> updatedNodes) |
Constructor and Description |
---|
RMAppNodeUpdateEvent(org.apache.hadoop.yarn.api.records.ApplicationId appId,
RMNode node,
RMAppNodeUpdateEvent.RMAppNodeUpdateType updateType) |
Modifier and Type | Class and Description |
---|---|
class |
RMNodeImpl
This class is used to keep track of all the applications/containers
running on a node.
|
Modifier and Type | Method and Description |
---|---|
RMNode |
RMNodeReconnectEvent.getReconnectedNode() |
Constructor and Description |
---|
RMNodeReconnectEvent(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) |
Modifier and Type | Method and Description |
---|---|
RMNode |
SchedulerNode.getRMNode() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractYarnScheduler.recoverContainersOnNode(List<org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus> containerReports,
RMNode nm) |
void |
AbstractYarnScheduler.updateNodeResource(RMNode nm,
org.apache.hadoop.yarn.api.records.ResourceOption resourceOption)
Process resource update on a node.
|
Constructor and Description |
---|
SchedulerNode(RMNode node,
boolean usePortForNodeName) |
SchedulerNode(RMNode node,
boolean usePortForNodeName,
Set<String> labels) |
Constructor and Description |
---|
FiCaSchedulerNode(RMNode node,
boolean usePortForNodeName) |
FiCaSchedulerNode(RMNode node,
boolean usePortForNodeName,
Set<String> nodeLabels) |
Modifier and Type | Method and Description |
---|---|
RMNode |
NodeAddedSchedulerEvent.getAddedRMNode() |
RMNode |
NodeRemovedSchedulerEvent.getRemovedRMNode() |
RMNode |
NodeUpdateSchedulerEvent.getRMNode() |
RMNode |
NodeResourceUpdateSchedulerEvent.getRMNode() |
Constructor and Description |
---|
NodeAddedSchedulerEvent(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) |
Modifier and Type | Method and Description |
---|---|
void |
FairScheduler.updateNodeResource(RMNode nm,
org.apache.hadoop.yarn.api.records.ResourceOption resourceOption)
Process resource update on a node and update Queue.
|
Constructor and Description |
---|
FSSchedulerNode(RMNode node,
boolean usePortForNodeName) |
Constructor and Description |
---|
NodeInfo(RMNode ni,
ResourceScheduler sched) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.