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 and 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 Detail

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 -