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

Class ConfigurationNodeAttributesProvider

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

All Implemented Interfaces:

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

public class ConfigurationNodeAttributesProvider
extends NodeAttributesProvider

Configuration based node attributes provider.

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

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.
Set<org.apache.hadoop.yarn.api.records.NodeAttribute>	parseAttributes(String config)
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

ConfigurationNodeAttributesProvider

public ConfigurationNodeAttributesProvider()

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

parseAttributes

@VisibleForTesting
public Set<org.apache.hadoop.yarn.api.records.NodeAttribute> parseAttributes(String config)
                                                                      throws IOException

Throws:

IOException

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.