org.apache.hadoop.yarn.server.nodemanager

Class NodeManager.NMContext

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.NodeManager.NMContext

All Implemented Interfaces:

Context

Enclosing class:

NodeManager

public static class NodeManager.NMContext
extends Object
implements Context

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,Application>	applications
protected ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container>	containers
protected ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,org.apache.hadoop.yarn.api.records.Container>	increasedContainers

Constructor Summary

Constructors

Constructor and Description
NodeManager.NMContext(NMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInNM nmTokenSecretManager, LocalDirsHandlerService dirsHandler, org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager, NMStateStoreService stateStore, boolean isDistSchedulingEnabled, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.yarn.server.security.ApplicationACLsManager	getApplicationACLsManager()
ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,Application>	getApplications()
org.apache.hadoop.conf.Configuration	getConf()
org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator	getContainerAllocator()
ContainerExecutor	getContainerExecutor()
ContainerManager	getContainerManager()
ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container>	getContainers()
ContainerStateTransitionListener	getContainerStateTransitionListener()
NMContainerTokenSecretManager	getContainerTokenSecretManager()
boolean	getDecommissioned()
int	getHttpPort() Return the node http-address.
ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,org.apache.hadoop.yarn.api.records.Container>	getIncreasedContainers()
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.
LocalDirsHandlerService	getLocalDirsHandler()
ConcurrentLinkedQueue<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport>	getLogAggregationStatusForApps()
NMStateStoreService	getNMStateStore()
NMTimelinePublisher	getNMTimelinePublisher()
NMTokenSecretManagerInNM	getNMTokenSecretManager()
org.apache.hadoop.yarn.server.api.records.NodeHealthStatus	getNodeHealthStatus()
org.apache.hadoop.yarn.api.records.NodeId	getNodeId() Usable only after ContainerManager is started.
NodeResourceMonitor	getNodeResourceMonitor()
NodeStatusUpdater	getNodeStatusUpdater()
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.
Map<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.security.Credentials>	getSystemCredentialsForApps()
boolean	isDistributedSchedulingEnabled()
void	setContainerExecutor(ContainerExecutor executor)
void	setContainerManager(ContainerManager containerManager)
void	setContainerStateTransitionListener(ContainerStateTransitionListener transitionListener)
void	setDecommissioned(boolean isDecommissioned)
void	setNMTimelinePublisher(NMTimelinePublisher nmMetricsPublisher)
void	setNodeId(org.apache.hadoop.yarn.api.records.NodeId nodeId)
void	setNodeResourceMonitor(NodeResourceMonitor nodeResourceMonitor)
void	setNodeStatusUpdater(NodeStatusUpdater nodeStatusUpdater)
void	setQueueableContainerAllocator(org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator containerAllocator)
void	setSystemCrendentialsForApps(Map<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.security.Credentials> systemCredentials)
void	setWebServer(WebServer webServer)

Methods inherited from class java.lang.Object

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

Field Detail

applications

protected final ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,Application> applications

containers

protected final ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> containers

increasedContainers

protected final ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,org.apache.hadoop.yarn.api.records.Container> increasedContainers

Constructor Detail

NodeManager.NMContext

public NodeManager.NMContext(NMContainerTokenSecretManager containerTokenSecretManager,
                     NMTokenSecretManagerInNM nmTokenSecretManager,
                     LocalDirsHandlerService dirsHandler,
                     org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager,
                     NMStateStoreService stateStore,
                     boolean isDistSchedulingEnabled,
                     org.apache.hadoop.conf.Configuration conf)

Method Detail

getNodeId

public org.apache.hadoop.yarn.api.records.NodeId getNodeId()

Usable only after ContainerManager is started.

Specified by:

getNodeId in interface Context

Returns:

the NodeId

getHttpPort

public int getHttpPort()

Description copied from interface: Context

Return the node http-address. Usable only after the Webserver is started.

Specified by:

getHttpPort in interface Context

Returns:

the http-port

getApplications

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

Specified by:

getApplications in interface Context

getConf

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

Specified by:

getConf in interface Context

getContainers

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

Specified by:

getContainers in interface Context

getIncreasedContainers

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

Specified by:

getIncreasedContainers in interface Context

getContainerTokenSecretManager

public NMContainerTokenSecretManager getContainerTokenSecretManager()

Specified by:

getContainerTokenSecretManager in interface Context

getNMTokenSecretManager

public NMTokenSecretManagerInNM getNMTokenSecretManager()

Specified by:

getNMTokenSecretManager in interface Context

getNodeHealthStatus

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

Specified by:

getNodeHealthStatus in interface Context

getNodeResourceMonitor

public NodeResourceMonitor getNodeResourceMonitor()

Specified by:

getNodeResourceMonitor in interface Context

setNodeResourceMonitor

public void setNodeResourceMonitor(NodeResourceMonitor nodeResourceMonitor)

getContainerManager

public ContainerManager getContainerManager()

Specified by:

getContainerManager in interface Context

setContainerManager

public void setContainerManager(ContainerManager containerManager)

setWebServer

public void setWebServer(WebServer webServer)

setNodeId

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

getLocalDirsHandler

public LocalDirsHandlerService getLocalDirsHandler()

Specified by:

getLocalDirsHandler in interface Context

getApplicationACLsManager

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

Specified by:

getApplicationACLsManager in interface Context

getNMStateStore

public NMStateStoreService getNMStateStore()

Specified by:

getNMStateStore in interface Context

getDecommissioned

public boolean getDecommissioned()

Specified by:

getDecommissioned in interface Context

setDecommissioned

public void setDecommissioned(boolean isDecommissioned)

Specified by:

setDecommissioned in interface Context

getSystemCredentialsForApps

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

Specified by:

getSystemCredentialsForApps in interface Context

setSystemCrendentialsForApps

public void setSystemCrendentialsForApps(Map<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.security.Credentials> systemCredentials)

getLogAggregationStatusForApps

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

Specified by:

getLogAggregationStatusForApps in interface Context

getNodeStatusUpdater

public NodeStatusUpdater getNodeStatusUpdater()

Specified by:

getNodeStatusUpdater in interface Context

setNodeStatusUpdater

public void setNodeStatusUpdater(NodeStatusUpdater nodeStatusUpdater)

isDistributedSchedulingEnabled

public boolean isDistributedSchedulingEnabled()

Specified by:

isDistributedSchedulingEnabled in interface Context

setQueueableContainerAllocator

public void setQueueableContainerAllocator(org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator containerAllocator)

getContainerAllocator

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

Specified by:

getContainerAllocator in interface Context

getContainerExecutor

public ContainerExecutor getContainerExecutor()

Specified by:

getContainerExecutor in interface Context

setContainerExecutor

public void setContainerExecutor(ContainerExecutor executor)

getContainerStateTransitionListener

public ContainerStateTransitionListener getContainerStateTransitionListener()

Specified by:

getContainerStateTransitionListener in interface Context

setContainerStateTransitionListener

public void setContainerStateTransitionListener(ContainerStateTransitionListener transitionListener)

getRegisteringCollectors

public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.server.api.records.AppCollectorData> getRegisteringCollectors()

Description copied from interface: Context

Get the list of collectors that are registering with the RM from this node.

Specified by:

getRegisteringCollectors in interface Context

Returns:

registering collectors, or null if the timeline service v.2 is not enabled

getKnownCollectors

public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.server.api.records.AppCollectorData> getKnownCollectors()

Description copied from interface: Context

Get the list of collectors registered with the RM and known by this node.

Specified by:

getKnownCollectors in interface Context

Returns:

known collectors, or null if the timeline service v.2 is not enabled.

setNMTimelinePublisher

public void setNMTimelinePublisher(NMTimelinePublisher nmMetricsPublisher)

Specified by:

setNMTimelinePublisher in interface Context

getNMTimelinePublisher

public NMTimelinePublisher getNMTimelinePublisher()

Specified by:

getNMTimelinePublisher in interface Context