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

Interface Context

All Known Implementing Classes:
NodeManager.NMContext
public interface Context
Context interface for sharing information across components in the NodeManager.

  • Method Details

    • getNodeId

      org.apache.hadoop.yarn.api.records.NodeId getNodeId()
      Return the nodeId. Usable only when the ContainerManager is started.
      Returns:
      the NodeId

    • getHttpPort

      int getHttpPort()
      Return the node http-address. Usable only after the Webserver is started.
      Returns:
      the http-port

    • getApplications

      ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,Application> getApplications()

    • getSystemCredentialsForApps

      Map<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.security.Credentials> getSystemCredentialsForApps()

    • getRegisteringCollectors

      ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.server.api.records.AppCollectorData> getRegisteringCollectors()
      Get the list of collectors that are registering with the RM from this node.
      Returns:
      registering collectors, or null if the timeline service v.2 is not enabled

    • getKnownCollectors

      ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.server.api.records.AppCollectorData> getKnownCollectors()
      Get the list of collectors registered with the RM and known by this node.
      Returns:
      known collectors, or null if the timeline service v.2 is not enabled.

    • getContainers

      ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> getContainers()

    • getIncreasedContainers

      ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,org.apache.hadoop.yarn.api.records.Container> getIncreasedContainers()

    • getContainerTokenSecretManager

      NMContainerTokenSecretManager getContainerTokenSecretManager()

    • getNMTokenSecretManager

      NMTokenSecretManagerInNM getNMTokenSecretManager()

    • getNodeHealthStatus

      org.apache.hadoop.yarn.server.api.records.NodeHealthStatus getNodeHealthStatus()

    • getContainerManager

      ContainerManager getContainerManager()

    • getNodeResourceMonitor

      NodeResourceMonitor getNodeResourceMonitor()

    • getLocalDirsHandler

      LocalDirsHandlerService getLocalDirsHandler()

    • getApplicationACLsManager

      org.apache.hadoop.yarn.server.security.ApplicationACLsManager getApplicationACLsManager()

    • getNMStateStore

      NMStateStoreService getNMStateStore()

    • getDecommissioned

      boolean getDecommissioned()

    • getConf

      org.apache.hadoop.conf.Configuration getConf()

    • setDecommissioned

      void setDecommissioned(boolean isDecommissioned)

    • getLogAggregationStatusForApps

      ConcurrentLinkedQueue<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> getLogAggregationStatusForApps()

    • getNodeStatusUpdater

      NodeStatusUpdater getNodeStatusUpdater()

    • isDistributedSchedulingEnabled

      boolean isDistributedSchedulingEnabled()

    • getContainerAllocator

      org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator getContainerAllocator()

    • setNMTimelinePublisher

      void setNMTimelinePublisher(NMTimelinePublisher nmMetricsPublisher)

    • getNMTimelinePublisher

      NMTimelinePublisher getNMTimelinePublisher()

    • getNMLogAggregationStatusTracker

      NMLogAggregationStatusTracker getNMLogAggregationStatusTracker()

    • getContainerExecutor

      ContainerExecutor getContainerExecutor()

    • getContainerStateTransitionListener

      ContainerStateTransitionListener getContainerStateTransitionListener()

    • getResourcePluginManager

      ResourcePluginManager getResourcePluginManager()

    • getNodeManagerMetrics

      NodeManagerMetrics getNodeManagerMetrics()

    • getDeletionService

      DeletionService getDeletionService()
      Get the DeletionService associated with the NM.
      Returns:
      the NM DeletionService.

    • setAuxServices

      void setAuxServices(AuxServices auxServices)

    • getAuxServices

      AuxServices getAuxServices()