Class RasBlacklistStrategy
java.lang.Object
org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategy
org.apache.storm.scheduler.blacklist.strategies.RasBlacklistStrategy
- All Implemented Interfaces:
IBlacklistStrategy
Blacklisting strategy just like the default one, but specifically setup for use with the resource aware scheduler.
-
Field Summary
Fields inherited from class org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategy
DEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME, DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategy
createHostToSupervisorMap, getBlacklist, prepare, resumeFromBlacklist
-
Constructor Details
-
RasBlacklistStrategy
public RasBlacklistStrategy()
-
-
Method Details
-
releaseBlacklistWhenNeeded
Description copied from class:DefaultBlacklistStrategyDecide when/if to release blacklisted hosts.- Overrides:
releaseBlacklistWhenNeededin classDefaultBlacklistStrategy- Parameters:
cluster- the current state of the cluster.blacklistedNodeIds- the current set of blacklisted node ids sorted by earliest- Returns:
- the set of nodes to be released.
-