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

Class DefaultResourceAwareStrategy

java.lang.Object

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

All Implemented Interfaces:

IStrategy

public class DefaultResourceAwareStrategy
extends Object
implements IStrategy

Constructor Summary

Constructors

Constructor and Description
DefaultResourceAwareStrategy()

Method Summary

Modifier and Type	Method and Description
RAS_Node	idToNode(String id) Find RAS_Node for specified node id
String	NodeHostnameToId(String hostname) hostname to Id
void	prepare(SchedulingState schedulingState) initialize prior to scheduling
SchedulingResult	schedule(TopologyDetails td) This method is invoked to calcuate a scheduling for topology td

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultResourceAwareStrategy

public DefaultResourceAwareStrategy()

Method Detail

prepare

public void prepare(SchedulingState schedulingState)

Description copied from interface: IStrategy

initialize prior to scheduling

Specified by:

prepare in interface IStrategy

schedule

public SchedulingResult schedule(TopologyDetails td)

Description copied from interface: IStrategy

This method is invoked to calcuate a scheduling for topology td

Specified by:

schedule in interface IStrategy

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.

NodeHostnameToId

public String NodeHostnameToId(String hostname)

hostname to Id

Parameters:

hostname - the hostname to convert to node id

Returns:

the id of a node

idToNode

public RAS_Node idToNode(String id)

Find RAS_Node for specified node id

Parameters:

id - the node/supervisor id to lookup

Returns:

a RAS_Node object