org.apache.hadoop.yarn.server.nodemanager.nodelabels

Class AbstractNodeLabelsProvider

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.nodemanager.nodelabels.AbstractNodeLabelsProvider

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, NodeLabelsProvider

Direct Known Subclasses:

ConfigurationNodeLabelsProvider, ScriptBasedNodeLabelsProvider

public abstract class AbstractNodeLabelsProvider
extends org.apache.hadoop.service.AbstractService
implements NodeLabelsProvider

Provides base implementation of NodeLabelsProvider with Timer and expects subclass to provide TimerTask which can fetch NodeLabels

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
static long	DISABLE_NODE_LABELS_PROVIDER_FETCH_TIMER
protected long	intervalTime
static String	NODE_LABELS_SEPRATOR
protected Set<org.apache.hadoop.yarn.api.records.NodeLabel>	nodeLabels
protected Timer	nodeLabelsScheduler
protected Lock	readLock
protected TimerTask	timerTask
protected Lock	writeLock

Constructor Summary

Constructors

Constructor and Description
AbstractNodeLabelsProvider(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	cleanUp() method for subclasses to cleanup.
abstract TimerTask	createTimerTask()
Set<org.apache.hadoop.yarn.api.records.NodeLabel>	getNodeLabels() Provides the labels.
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop() terminate the timer
protected void	setNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeLabel> nodeLabelsSet)

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Field Detail

DISABLE_NODE_LABELS_PROVIDER_FETCH_TIMER

public static final long DISABLE_NODE_LABELS_PROVIDER_FETCH_TIMER

See Also:

Constant Field Values

intervalTime

protected long intervalTime

nodeLabelsScheduler

protected Timer nodeLabelsScheduler

NODE_LABELS_SEPRATOR

public static final String NODE_LABELS_SEPRATOR

See Also:

Constant Field Values

readLock

protected Lock readLock

writeLock

protected Lock writeLock

timerTask

protected TimerTask timerTask

nodeLabels

protected Set<org.apache.hadoop.yarn.api.records.NodeLabel> nodeLabels

Constructor Detail

AbstractNodeLabelsProvider

public AbstractNodeLabelsProvider(String name)

Method Detail

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

terminate the timer

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

cleanUp

protected abstract void cleanUp()
                         throws Exception

method for subclasses to cleanup.

Throws:

Exception

getNodeLabels

public Set<org.apache.hadoop.yarn.api.records.NodeLabel> getNodeLabels()

Description copied from interface: NodeLabelsProvider

Provides the labels. LabelProvider is expected to give same Labels continuously until there is a change in labels. If null is returned then Empty label set is assumed by the caller.

Specified by:

getNodeLabels in interface NodeLabelsProvider

Returns:

Returns output from provider.

setNodeLabels

protected void setNodeLabels(Set<org.apache.hadoop.yarn.api.records.NodeLabel> nodeLabelsSet)

createTimerTask

public abstract TimerTask createTimerTask()