public class RMDelegatedNodeLabelsUpdater
extends org.apache.hadoop.service.CompositeService
RMNodeLabelsMappingProvider
and updates the
nodes -> labels map via RMNodeLabelsManager
.
This service is enabled when configuration
"yarn.node-labels.configuration-type" is set to "delegated-centralized".Modifier and Type | Field and Description |
---|---|
static long |
DISABLE_DELEGATED_NODE_LABELS_UPDATE |
long |
nodeLabelsUpdateInterval |
Constructor and Description |
---|
RMDelegatedNodeLabelsUpdater(RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop()
Terminate the timer.
|
void |
updateNodeLabels(org.apache.hadoop.yarn.api.records.NodeId node)
Update node labels for a specified node.
|
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final long DISABLE_DELEGATED_NODE_LABELS_UPDATE
public long nodeLabelsUpdateInterval
public RMDelegatedNodeLabelsUpdater(RMContext rmContext)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public void updateNodeLabels(org.apache.hadoop.yarn.api.records.NodeId node)
node
- the node to update node labelsCopyright © 2017 Apache Software Foundation. All Rights Reserved.