Class GenericResourceAwareSchedulingPriorityStrategy
java.lang.Object
org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy
org.apache.storm.scheduler.resource.strategies.priority.GenericResourceAwareSchedulingPriorityStrategy
- All Implemented Interfaces:
ISchedulingPriorityStrategy
public class GenericResourceAwareSchedulingPriorityStrategy
extends DefaultSchedulingPriorityStrategy
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static class
Nested classes/interfaces inherited from class org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy
DefaultSchedulingPriorityStrategy.SimulatedUser
-
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
-
GenericResourceAwareSchedulingPriorityStrategy
public GenericResourceAwareSchedulingPriorityStrategy()
-
-
Method Details
-
getSimulatedUserFor
protected GenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUser getSimulatedUserFor(User u, ISchedulingState cluster) - Overrides:
getSimulatedUserFor
in classDefaultSchedulingPriorityStrategy
-
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
- Overrides:
getOrderedTopologies
in classDefaultSchedulingPriorityStrategy
- Returns:
- ordered list of topologies to schedule.
-