org.apache.storm.scheduler.resource.strategies.scheduling

Interface IStrategy

All Known Implementing Classes:

DefaultResourceAwareStrategy

public interface IStrategy

An interface to for implementing different scheduling strategies for the resource aware scheduling In the future stategies will be pluggable

Method Summary

Modifier and Type	Method and Description
void	prepare(SchedulingState schedulingState) initialize prior to scheduling
SchedulingResult	schedule(TopologyDetails td) This method is invoked to calcuate a scheduling for topology td

Method Detail

prepare

void prepare(SchedulingState schedulingState)

initialize prior to scheduling

schedule

SchedulingResult schedule(TopologyDetails td)

This method is invoked to calcuate a scheduling for topology td

Parameters:

td -

Returns:

returns a SchedulingResult object containing SchedulingStatus object to indicate whether scheduling is successful The strategy must calculate a scheduling in the format of Map<WorkerSlot, Collection> where the key of this map is the worker slot that the value (collection of executors) should be assigned to. if a scheduling is calculated successfully, put the scheduling map in the SchedulingResult object. PLEASE NOTE: Any other operations done on the cluster from a scheduling strategy will NOT persist or be realized. The data structures passed in can be used in any way necessary to assist in calculating a scheduling, but will NOT actually change the state of the cluster.