public class RMNodeLabelsManager
extends org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
Modifier and Type | Class and Description |
---|---|
protected static class |
RMNodeLabelsManager.Queue |
Constructor and Description |
---|
RMNodeLabelsManager() |
Modifier and Type | Method and Description |
---|---|
void |
activateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.Resource resource) |
void |
addLabelsToNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> addedLabelsToNode) |
void |
addToCluserNodeLabels(Collection<org.apache.hadoop.yarn.api.records.NodeLabel> labels) |
boolean |
checkAccess(org.apache.hadoop.security.UserGroupInformation user) |
protected void |
checkRemoveFromClusterNodeLabelsOfQueue(Collection<String> labelsToRemove) |
boolean |
containsNodeLabel(String label) |
void |
deactivateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
Set<String> |
getLabelsOnNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
org.apache.hadoop.yarn.api.records.Resource |
getQueueResource(String queueName,
Set<String> queueLabels,
org.apache.hadoop.yarn.api.records.Resource clusterResource) |
org.apache.hadoop.yarn.api.records.Resource |
getResourceByLabel(String label,
org.apache.hadoop.yarn.api.records.Resource clusterResource) |
List<org.apache.hadoop.yarn.nodelabels.RMNodeLabel> |
pullRMNodeLabelsInfo() |
void |
reinitializeQueueLabels(Map<String,Set<String>> queueToLabels) |
void |
removeFromClusterNodeLabels(Collection<String> labelsToRemove) |
void |
removeLabelsFromNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> removeLabelsFromNode) |
void |
replaceLabelsOnNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> replaceLabelsToNode) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
void |
setRMContext(RMContext rmContext) |
void |
updateNodeResource(org.apache.hadoop.yarn.api.records.NodeId node,
org.apache.hadoop.yarn.api.records.Resource newResource) |
addToCluserNodeLabelsWithDefaultExclusivity, checkAddLabelsToNode, checkAndThrowLabelName, checkRemoveFromClusterNodeLabels, checkRemoveLabelsFromNode, checkReplaceLabelsOnNode, createHostIfNonExisted, createNodeIfNonExisted, getClusterNodeLabelNames, getClusterNodeLabels, getLabelsByNode, getLabelsByNode, getLabelsInfoByNode, getLabelsInfoToNodes, getLabelsInfoToNodes, getLabelsToNodes, getLabelsToNodes, getNMInNodeSet, getNMInNodeSet, getNMInNodeSet, getNodeLabels, getNodeLabelsInfo, handleStoreEvent, initDispatcher, initNodeLabelStore, internalRemoveFromClusterNodeLabels, internalUpdateLabelsOnNodes, isExclusiveNodeLabel, isInitNodeLabelStoreInProgress, normalizeLabel, normalizeNodeIdToLabels, removeNodeFromLabels, serviceStart, serviceStop, setInitNodeLabelStoreInProgress, startDispatcher, stopDispatcher
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
Exception
public void addLabelsToNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> addedLabelsToNode) throws IOException
addLabelsToNode
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
IOException
protected void checkRemoveFromClusterNodeLabelsOfQueue(Collection<String> labelsToRemove) throws IOException
IOException
public void removeFromClusterNodeLabels(Collection<String> labelsToRemove) throws IOException
removeFromClusterNodeLabels
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
IOException
public void addToCluserNodeLabels(Collection<org.apache.hadoop.yarn.api.records.NodeLabel> labels) throws IOException
addToCluserNodeLabels
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
IOException
public void removeLabelsFromNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> removeLabelsFromNode) throws IOException
removeLabelsFromNode
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
IOException
public void replaceLabelsOnNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> replaceLabelsToNode) throws IOException
replaceLabelsOnNode
in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
IOException
public void activateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.Resource resource)
public void deactivateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
public void updateNodeResource(org.apache.hadoop.yarn.api.records.NodeId node, org.apache.hadoop.yarn.api.records.Resource newResource)
public org.apache.hadoop.yarn.api.records.Resource getQueueResource(String queueName, Set<String> queueLabels, org.apache.hadoop.yarn.api.records.Resource clusterResource)
public Set<String> getLabelsOnNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
public boolean containsNodeLabel(String label)
public org.apache.hadoop.yarn.api.records.Resource getResourceByLabel(String label, org.apache.hadoop.yarn.api.records.Resource clusterResource)
public boolean checkAccess(org.apache.hadoop.security.UserGroupInformation user)
public void setRMContext(RMContext rmContext)
public List<org.apache.hadoop.yarn.nodelabels.RMNodeLabel> pullRMNodeLabelsInfo()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.