public class NodesListManager extends org.apache.hadoop.service.AbstractService implements org.apache.hadoop.yarn.event.EventHandler<NodesListManagerEvent>
Constructor and Description |
---|
NodesListManager(RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.util.HostsFileReader |
getHostsReader() |
int |
getUnusableNodes(Collection<RMNode> unUsableNodes)
Provides the currently unusable nodes.
|
void |
handle(NodesListManagerEvent event) |
boolean |
isValidNode(String hostName) |
void |
refreshNodes(org.apache.hadoop.conf.Configuration yarnConf) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceStart, serviceStop, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public NodesListManager(RMContext rmContext)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
public void refreshNodes(org.apache.hadoop.conf.Configuration yarnConf) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
public boolean isValidNode(String hostName)
public int getUnusableNodes(Collection<RMNode> unUsableNodes)
unUsableNodes
- Collection to which the unusable nodes are addedpublic void handle(NodesListManagerEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<NodesListManagerEvent>
public org.apache.hadoop.util.HostsFileReader getHostsReader()
Copyright © 2015 Apache Software Foundation. All Rights Reserved.