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 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() Return the nodeId.
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	setDecommissioned(boolean isDecommissioned)
void	setNMTimelinePublisher(NMTimelinePublisher nmMetricsPublisher)

Method Detail

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()

getContainerExecutor

ContainerExecutor getContainerExecutor()

getContainerStateTransitionListener

ContainerStateTransitionListener getContainerStateTransitionListener()

setNMTimelinePublisher

void setNMTimelinePublisher(NMTimelinePublisher nmMetricsPublisher)

getNMTimelinePublisher

NMTimelinePublisher getNMTimelinePublisher()