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

Class ScriptBasedNodeLabelsProvider

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.nodemanager.nodelabels.AbstractNodeDescriptorsProvider<org.apache.hadoop.yarn.api.records.NodeLabel>

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, NodeDescriptorsProvider<org.apache.hadoop.yarn.api.records.NodeLabel>

public class ScriptBasedNodeLabelsProvider
extends NodeLabelsProvider

The class which provides functionality of getting the labels of the node using the configured node labels provider script. "NODE_PARTITION:" is the pattern which will be used to search node label partition from the out put of the NodeLabels provider script

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	Description
static final String	NODE_LABEL_PARTITION_PATTERN	Pattern used for searching in the output of the node labels script

Fields inherited from class org.apache.hadoop.yarn.server.nodemanager.nodelabels.AbstractNodeDescriptorsProvider

DISABLE_NODE_DESCRIPTORS_PROVIDER_FETCH_TIMER, readLock, timerTask, writeLock

Constructor Summary

Constructors

Constructor	Description
ScriptBasedNodeLabelsProvider()

Method Summary

Modifier and Type	Method	Description
void	cleanUp()	Method used to terminate the Node Labels Fetch script.
TimerTask	createTimerTask()	Creates a timer task which be scheduled periodically by the provider, and the task is responsible to update node descriptors to the provider.
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.yarn.server.nodemanager.nodelabels.AbstractNodeDescriptorsProvider

getDescriptors, getIntervalTime, getScheduler, serviceStart, serviceStop, setDescriptors, setIntervalTime, verifyConfiguredScript

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 Details

NODE_LABEL_PARTITION_PATTERN

public static final String NODE_LABEL_PARTITION_PATTERN

Pattern used for searching in the output of the node labels script

See Also:

• Constant Field Values

Constructor Details

ScriptBasedNodeLabelsProvider

public ScriptBasedNodeLabelsProvider()

Method Details

serviceInit

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

Overrides:

serviceInit in class AbstractNodeDescriptorsProvider<org.apache.hadoop.yarn.api.records.NodeLabel>

Throws:

Exception

cleanUp

public void cleanUp()

Method used to terminate the Node Labels Fetch script.

Specified by:

cleanUp in class AbstractNodeDescriptorsProvider<org.apache.hadoop.yarn.api.records.NodeLabel>

createTimerTask

public TimerTask createTimerTask()

Description copied from class: AbstractNodeDescriptorsProvider

Creates a timer task which be scheduled periodically by the provider, and the task is responsible to update node descriptors to the provider.

Specified by:

createTimerTask in class AbstractNodeDescriptorsProvider<org.apache.hadoop.yarn.api.records.NodeLabel>

Returns:

a timer task.