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

Class ScriptBasedNodeAttributesProvider

java.lang.Object

org.apache.hadoop.service.AbstractService

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

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

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

All Implemented Interfaces:

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

public class ScriptBasedNodeAttributesProvider
extends NodeAttributesProvider

Node attribute provider that periodically runs a script to collect node attributes.

Nested Class Summary

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

org.apache.hadoop.service.Service.STATE

Field Summary

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

Method Summary

Modifier and Type	Method	Description
protected void	cleanUp()	method for subclasses to cleanup.
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

Constructor Details

ScriptBasedNodeAttributesProvider

public ScriptBasedNodeAttributesProvider()

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.NodeAttribute>

Throws:

Exception

cleanUp

protected void cleanUp()
                throws Exception

Description copied from class: AbstractNodeDescriptorsProvider

method for subclasses to cleanup.

Specified by:

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

Throws:

Exception

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.NodeAttribute>

Returns:

a timer task.