Package org.apache.hadoop.yarn.server.resourcemanager.nodelabels

Class RMNodeLabelsManager

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
org.apache.hadoop.yarn.server.resourcemanager.nodelabels.RMNodeLabelsManager
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service
public class RMNodeLabelsManager extends org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected static class 
    RMNodeLabelsManager.Queue
     

    Nested classes/interfaces inherited from class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager

    org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager.Host, org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager.Node

    Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

    org.apache.hadoop.service.Service.STATE

  • Field Summary

    Fields inherited from class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager

    ACCESS_ANY_LABEL_SET, ANY, dispatcher, EMPTY_NODELABEL_SET, EMPTY_STRING_SET, labelCollections, LOG, NO_LABEL, NODE_LABELS_NOT_ENABLED_ERR, nodeCollections, noNodeLabel, readLock, store, WILDCARD_PORT, writeLock

  • Constructor Summary

    Constructors
    Constructor
    Description
    RMNodeLabelsManager()
     

  • Method Summary

    Modifier and Type
    Method
    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)
     
    int
    getActiveNMCountPerLabel(String label)
     
    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)
     

    Methods inherited from class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager

    addToCluserNodeLabelsWithDefaultExclusivity, checkAddLabelsToNode, checkRemoveFromClusterNodeLabels, checkRemoveLabelsFromNode, checkReplaceLabelsOnNode, createHostIfNonExisted, createNodeIfNonExisted, getClusterNodeLabelNames, getClusterNodeLabels, getLabelsByNode, getLabelsByNode, getLabelsInfoByNode, getLabelsInfoToNodes, getLabelsInfoToNodes, getLabelsToNodes, getLabelsToNodes, getNMInNodeSet, getNMInNodeSet, getNMInNodeSet, getNodeLabels, getNodeLabelsInfo, getNodesWithoutALabel, handleStoreEvent, initDispatcher, initNodeLabelStore, internalRemoveFromClusterNodeLabels, internalUpdateLabelsOnNodes, isCentralizedConfiguration, isExclusiveNodeLabel, isInitNodeLabelStoreInProgress, isNodeLabelExplicit, normalizeLabel, normalizeNodeIdToLabels, removeLabelsFromNodeInHost, removeNodeFromLabels, serviceStart, serviceStop, setInitNodeLabelStoreInProgress, startDispatcher, stopDispatcher

    Methods inherited from class org.apache.hadoop.service.AbstractService

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • RMNodeLabelsManager

      public RMNodeLabelsManager()

  • Method Details

    • serviceInit

      protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
      Overrides:
      serviceInit in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      Exception

    • addLabelsToNode

      public void addLabelsToNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> addedLabelsToNode) throws IOException
      Overrides:
      addLabelsToNode in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      IOException

    • checkRemoveFromClusterNodeLabelsOfQueue

      protected void checkRemoveFromClusterNodeLabelsOfQueue(Collection<String> labelsToRemove) throws IOException
      Throws:
      IOException

    • removeFromClusterNodeLabels

      public void removeFromClusterNodeLabels(Collection<String> labelsToRemove) throws IOException
      Overrides:
      removeFromClusterNodeLabels in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      IOException

    • addToCluserNodeLabels

      public void addToCluserNodeLabels(Collection<org.apache.hadoop.yarn.api.records.NodeLabel> labels) throws IOException
      Overrides:
      addToCluserNodeLabels in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      IOException

    • removeLabelsFromNode

      public void removeLabelsFromNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> removeLabelsFromNode) throws IOException
      Overrides:
      removeLabelsFromNode in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      IOException

    • replaceLabelsOnNode

      public void replaceLabelsOnNode(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> replaceLabelsToNode) throws IOException
      Overrides:
      replaceLabelsOnNode in class org.apache.hadoop.yarn.nodelabels.CommonNodeLabelsManager
      Throws:
      IOException

    • activateNode

      public void activateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.Resource resource)

    • deactivateNode

      public void deactivateNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)

    • updateNodeResource

      public void updateNodeResource(org.apache.hadoop.yarn.api.records.NodeId node, org.apache.hadoop.yarn.api.records.Resource newResource)

    • reinitializeQueueLabels

      public void reinitializeQueueLabels(Map<String,Set<String>> queueToLabels)

    • getQueueResource

      public org.apache.hadoop.yarn.api.records.Resource getQueueResource(String queueName, Set<String> queueLabels, org.apache.hadoop.yarn.api.records.Resource clusterResource)

    • getActiveNMCountPerLabel

      public int getActiveNMCountPerLabel(String label)

    • getLabelsOnNode

      public Set<String> getLabelsOnNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)

    • containsNodeLabel

      public boolean containsNodeLabel(String label)

    • getResourceByLabel

      public org.apache.hadoop.yarn.api.records.Resource getResourceByLabel(String label, org.apache.hadoop.yarn.api.records.Resource clusterResource)

    • checkAccess

      public boolean checkAccess(org.apache.hadoop.security.UserGroupInformation user)

    • setRMContext

      public void setRMContext(RMContext rmContext)

    • pullRMNodeLabelsInfo

      public List<org.apache.hadoop.yarn.nodelabels.RMNodeLabel> pullRMNodeLabelsInfo()