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 Summary
Nested ClassesModifier and TypeClassDescriptionprotected static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiongetOrderedTopologies
(ISchedulingState cluster, Map<String, User> userMap) Prioritize the list of all topologies in the cluster.getSimulatedUserFor
(User u, ISchedulingState cluster)
-
Constructor Details
-
DefaultSchedulingPriorityStrategy
public DefaultSchedulingPriorityStrategy()
-
-
Method Details
-
getSimulatedUserFor
protected DefaultSchedulingPriorityStrategy.SimulatedUser getSimulatedUserFor(User u, ISchedulingState cluster) -
getOrderedTopologies
public List<TopologyDetails> getOrderedTopologies(ISchedulingState cluster, Map<String, User> userMap) Description copied from interface:ISchedulingPriorityStrategy
Prioritize the list of all topologies in the cluster.- Specified by:
getOrderedTopologies
in interfaceISchedulingPriorityStrategy
- Returns:
- ordered list of topologies to schedule.
-