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

Class RMNodeLabelsMappingProvider

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.resourcemanager.nodelabels.RMNodeLabelsMappingProvider
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service
public abstract class RMNodeLabelsMappingProvider extends org.apache.hadoop.service.AbstractService
Interface which is responsible for providing the node -> labels map.

  • Nested Class Summary

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

    org.apache.hadoop.service.Service.STATE

  • Constructor Summary

    Constructors
    Constructor
    Description
    RMNodeLabelsMappingProvider(String name)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract Map<org.apache.hadoop.yarn.api.records.NodeId,Set<org.apache.hadoop.yarn.api.records.NodeLabel>>
    getNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeId> nodes)
    Provides the labels.

    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, serviceInit, serviceStart, serviceStop, 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

    • RMNodeLabelsMappingProvider

      public RMNodeLabelsMappingProvider(String name)

  • Method Details

    • getNodeLabels

      public abstract Map<org.apache.hadoop.yarn.api.records.NodeId,Set<org.apache.hadoop.yarn.api.records.NodeLabel>> getNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeId> nodes)
      Provides the labels. It is expected to give same Labels continuously until there is a change in labels.
      Parameters:
      nodes - to fetch labels
      Returns:
      Set of node label strings applicable for a node