Package org.apache.hadoop.yarn.server.nodemanager

Interface NodeStatusUpdater

All Superinterfaces:
AutoCloseable, Closeable, org.apache.hadoop.service.Service
All Known Implementing Classes:
NodeStatusUpdaterImpl
public interface NodeStatusUpdater extends org.apache.hadoop.service.Service

  • Nested Class Summary

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

    org.apache.hadoop.service.Service.STATE

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addCompletedContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
    Add a container to the list of containers that have recently completed
    void
    clearFinishedContainersFromCache()
    Clear the list of recently completed containers
    long
    getRMIdentifier()
    Get the ResourceManager identifier received during registration
    boolean
    isContainerRecentlyStopped(org.apache.hadoop.yarn.api.records.ContainerId containerId)
    Query if a container has recently completed
    void
    reportException(Exception ex)
    Report an unrecoverable exception.
    void
    sendOutofBandHeartBeat()
    Schedule a heartbeat to the ResourceManager outside of the normal, periodic heartbeating process.
    void
    setNodeAttributesProvider(NodeAttributesProvider provider)
    Sets a node attributes provider to node manager.
    void
    setNodeLabelsProvider(NodeLabelsProvider provider)
    Sets a node labels provider to the node manager.

    Methods inherited from interface org.apache.hadoop.service.Service

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop

  • Method Details

    • sendOutofBandHeartBeat

      void sendOutofBandHeartBeat()
      Schedule a heartbeat to the ResourceManager outside of the normal, periodic heartbeating process. This is typically called when the state of containers on the node has changed to notify the RM sooner.

    • getRMIdentifier

      long getRMIdentifier()
      Get the ResourceManager identifier received during registration
      Returns:
      the ResourceManager ID

    • isContainerRecentlyStopped

      boolean isContainerRecentlyStopped(org.apache.hadoop.yarn.api.records.ContainerId containerId)
      Query if a container has recently completed
      Parameters:
      containerId - the container ID
      Returns:
      true if the container has recently completed

    • addCompletedContainer

      void addCompletedContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
      Add a container to the list of containers that have recently completed
      Parameters:
      containerId - the ID of the completed container

    • clearFinishedContainersFromCache

      void clearFinishedContainersFromCache()
      Clear the list of recently completed containers

    • reportException

      void reportException(Exception ex)
      Report an unrecoverable exception.
      Parameters:
      ex - exception that makes the node unhealthy

    • setNodeAttributesProvider

      void setNodeAttributesProvider(NodeAttributesProvider provider)
      Sets a node attributes provider to node manager.
      Parameters:
      provider -

    • setNodeLabelsProvider

      void setNodeLabelsProvider(NodeLabelsProvider provider)
      Sets a node labels provider to the node manager.
      Parameters:
      provider -