Class DefaultSchedulingPriorityStrategy.SimulatedUser
java.lang.Object
org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy.SimulatedUser
- Direct Known Subclasses:
- FIFOSchedulingPriorityStrategy.FIFOSimulatedUser,- GenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUser
- Enclosing class:
- DefaultSchedulingPriorityStrategy
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected doubleprotected doublefinal doublefinal doubleprotected final LinkedList<TopologyDetails>
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptiondoublegetScore(double availableCpu, double availableMemory) protected doublegetScore(double availableCpu, double availableMemory, TopologyDetails td) Get a score for the simulated user.
- 
Field Details- 
guaranteedCpupublic final double guaranteedCpu
- 
guaranteedMemorypublic final double guaranteedMemory
- 
tds
- 
assignedCpuprotected double assignedCpu
- 
assignedMemoryprotected double assignedMemory
 
- 
- 
Constructor Details- 
SimulatedUser
 
- 
- 
Method Details- 
getNextHighest
- 
simScheduleNextHighest
- 
getScoreGet a score for the simulated user. This is used to sort the users, by their highest priority topology. The only requirement is that if the user is over their guarantees, or there are no available resources the returned score will be > 0. If they are under their guarantee it must be negative.- Parameters:
- availableCpu- available CPU on the cluster.
- availableMemory- available memory on the cluster.
- td- the topology we are looking at.
- Returns:
- the score.
 
- 
getScorepublic double getScore(double availableCpu, double availableMemory) 
 
-