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 Classes Modifier and Type Class Description protected static classGenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUser-
Nested classes/interfaces inherited from class org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy
DefaultSchedulingPriorityStrategy.SimulatedUser
-
-
Constructor Summary
Constructors Constructor Description GenericResourceAwareSchedulingPriorityStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<TopologyDetails>getOrderedTopologies(ISchedulingState cluster, Map<String,User> userMap)Prioritize the list of all topologies in the cluster.protected GenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUsergetSimulatedUserFor(User u, ISchedulingState cluster)
-
-
-
Method Detail
-
getSimulatedUserFor
protected GenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUser getSimulatedUserFor(User u, ISchedulingState cluster)
- Overrides:
getSimulatedUserForin classDefaultSchedulingPriorityStrategy
-
getOrderedTopologies
public 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 interfaceISchedulingPriorityStrategy- Overrides:
getOrderedTopologiesin classDefaultSchedulingPriorityStrategy- Returns:
- ordered list of topologies to schedule.
-
-