Class DefaultSchedulingPriorityStrategy
java.lang.Object
org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy
- All Implemented Interfaces:
- ISchedulingPriorityStrategy
- Direct Known Subclasses:
- FIFOSchedulingPriorityStrategy,- GenericResourceAwareSchedulingPriorityStrategy
public class DefaultSchedulingPriorityStrategy
extends Object
implements ISchedulingPriorityStrategy
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionprotected static class
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptiongetOrderedTopologies(ISchedulingState cluster, Map<String, User> userMap) Prioritize the list of all topologies in the cluster.getSimulatedUserFor(User u, ISchedulingState cluster) 
- 
Constructor Details- 
DefaultSchedulingPriorityStrategypublic DefaultSchedulingPriorityStrategy()
 
- 
- 
Method Details- 
getSimulatedUserForprotected DefaultSchedulingPriorityStrategy.SimulatedUser getSimulatedUserFor(User u, ISchedulingState cluster) 
- 
getOrderedTopologiespublic List<TopologyDetails> getOrderedTopologies(ISchedulingState cluster, Map<String, User> userMap) Description copied from interface:ISchedulingPriorityStrategyPrioritize the list of all topologies in the cluster.- Specified by:
- getOrderedTopologiesin interface- ISchedulingPriorityStrategy
- Returns:
- ordered list of topologies to schedule.
 
 
-