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

Modifier and Type	Method and Description
org.apache.hadoop.yarn.server.security.ApplicationACLsManager	getApplicationACLsManager()
ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,Application>	getApplications()
AuxServices	getAuxServices()
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()
DeletionService	getDeletionService() Get the DeletionService associated with the NM.
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()
NMLogAggregationStatusTracker	getNMLogAggregationStatusTracker()
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.
NodeManagerMetrics	getNodeManagerMetrics()
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.
ResourcePluginManager	getResourcePluginManager()
Map<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.security.Credentials>	getSystemCredentialsForApps()
boolean	isDistributedSchedulingEnabled()
void	setAuxServices(AuxServices auxServices)
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()

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