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 SummaryFields inherited from class org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategyDEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME, DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT
- 
Constructor SummaryConstructors
- 
Method SummaryMethods inherited from class org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategycreateHostToSupervisorMap, getBlacklist, prepare, resumeFromBlacklist
- 
Constructor Details- 
RasBlacklistStrategypublic RasBlacklistStrategy()
 
- 
- 
Method Details- 
releaseBlacklistWhenNeededDescription copied from class:DefaultBlacklistStrategyDecide when/if to release blacklisted hosts.- Overrides:
- releaseBlacklistWhenNeededin class- DefaultBlacklistStrategy
- 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.
 
 
-