public class SimpleBlacklistManager extends Object implements BlacklistManager
Constructor and Description |
---|
SimpleBlacklistManager(int numberOfNodeManagerHosts,
double blacklistDisableFailureThreshold) |
Modifier and Type | Method and Description |
---|---|
void |
addNode(String node)
Report failure of a container on node.
|
org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest |
getBlacklistUpdates()
Get
ResourceBlacklistRequest that indicate which nodes should be
added or to removed from the blacklist. |
void |
refreshNodeHostCount(int nodeHostCount)
Refresh the number of NodeManagers available for scheduling.
|
public SimpleBlacklistManager(int numberOfNodeManagerHosts, double blacklistDisableFailureThreshold)
public void addNode(String node)
BlacklistManager
addNode
in interface BlacklistManager
node
- that has a container failurepublic void refreshNodeHostCount(int nodeHostCount)
BlacklistManager
refreshNodeHostCount
in interface BlacklistManager
nodeHostCount
- is the number of node hosts.public org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest getBlacklistUpdates()
BlacklistManager
ResourceBlacklistRequest
that indicate which nodes should be
added or to removed from the blacklist.getBlacklistUpdates
in interface BlacklistManager
ResourceBlacklistRequest
Copyright © 2017 Apache Software Foundation. All Rights Reserved.