org.apache.storm.scheduler.resource.strategies.priority

Class DefaultSchedulingPriorityStrategy

java.lang.Object

org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy

All Implemented Interfaces:

ISchedulingPriorityStrategy

public class DefaultSchedulingPriorityStrategy
extends Object
implements ISchedulingPriorityStrategy

Constructor Summary

Constructors

Constructor and Description
DefaultSchedulingPriorityStrategy()

Method Summary

Modifier and Type	Method and Description
TopologyDetails	getNextTopologyToSchedule() Gets the next topology to schedule
User	getNextUser()
void	prepare(SchedulingState schedulingState) initializes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSchedulingPriorityStrategy

public DefaultSchedulingPriorityStrategy()

Method Detail

prepare

public void prepare(SchedulingState schedulingState)

Description copied from interface: ISchedulingPriorityStrategy

initializes

Specified by:

prepare in interface ISchedulingPriorityStrategy

getNextTopologyToSchedule

public TopologyDetails getNextTopologyToSchedule()

Description copied from interface: ISchedulingPriorityStrategy

Gets the next topology to schedule

Specified by:

getNextTopologyToSchedule in interface ISchedulingPriorityStrategy

Returns:

return the next topology to schedule. If there is no topologies left to schedule, return null

getNextUser

public User getNextUser()