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

Class ConstraintSolverStrategy

java.lang.Object

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

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

All Implemented Interfaces:

IStrategy

public class ConstraintSolverStrategy
extends BaseResourceAwareStrategy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ConstraintSolverStrategy.SearcherState
protected static class	ConstraintSolverStrategy.SolverResult

Nested classes/interfaces inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy

BaseResourceAwareStrategy.AllResources, BaseResourceAwareStrategy.ExistingScheduleFunc, BaseResourceAwareStrategy.ObjectResources

Field Summary

Fields inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy

cluster

Constructor Summary

Constructors

Constructor and Description
ConstraintSolverStrategy()

Method Summary

Modifier and Type	Method and Description
protected ConstraintSolverStrategy.SolverResult	backtrackSearch(ConstraintSolverStrategy.SearcherState state)
boolean	isExecAssignmentToWorkerValid(WorkerSlot worker, ConstraintSolverStrategy.SearcherState state) Check if any constraints are violated if exec is scheduled on worker.
SchedulingResult	schedule(Cluster cluster, TopologyDetails td) This method is invoked to calculate a scheduling for topology td.
<K extends Comparable<K>,V extends Comparable<V>> NavigableMap<K,V>	sortByValues(Map<K,V> map) Used to sort a Map by the values.
protected TreeSet<BaseResourceAwareStrategy.ObjectResources>	sortObjectResources(BaseResourceAwareStrategy.AllResources allResources, ExecutorDetails exec, TopologyDetails topologyDetails, BaseResourceAwareStrategy.ExistingScheduleFunc existingScheduleFunc)
static boolean	validateSolution(Cluster cluster, TopologyDetails td) Determines if a scheduling is valid and all constraints are satisfied.

Methods inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy

findWorkerForExec, getSpouts, hostnameToNodes, idToNode, makeHostToNodeIds, mkNotEnoughResources, nodeToRack, orderExecutors, prepare, scheduleExecutor, sortAllNodes, sortNodes

Methods inherited from class java.lang.Object

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

Constructor Detail

ConstraintSolverStrategy

public ConstraintSolverStrategy()

Method Detail

validateSolution

public static boolean validateSolution(Cluster cluster,
                                       TopologyDetails td)

Determines if a scheduling is valid and all constraints are satisfied.

schedule

public SchedulingResult schedule(Cluster cluster,
                                 TopologyDetails td)

Description copied from interface: IStrategy

This method is invoked to calculate a scheduling for topology td. Cluster will reject any changes that are not for the given topology. Any changes made to the cluster will be committed if the scheduling is successful.

NOTE: scheduling occurs as a runnable in an interruptible thread. Scheduling should consider being interrupted if long running.

Parameters:

cluster - the current state of the cluster

td - the topology to schedule for

Returns:

returns a SchedulingResult object containing SchedulingStatus object to indicate whether scheduling is successful.

sortObjectResources

protected TreeSet<BaseResourceAwareStrategy.ObjectResources> sortObjectResources(BaseResourceAwareStrategy.AllResources allResources,
                                                                                 ExecutorDetails exec,
                                                                                 TopologyDetails topologyDetails,
                                                                                 BaseResourceAwareStrategy.ExistingScheduleFunc existingScheduleFunc)

Specified by:

sortObjectResources in class BaseResourceAwareStrategy

backtrackSearch

protected ConstraintSolverStrategy.SolverResult backtrackSearch(ConstraintSolverStrategy.SearcherState state)

isExecAssignmentToWorkerValid

public boolean isExecAssignmentToWorkerValid(WorkerSlot worker,
                                             ConstraintSolverStrategy.SearcherState state)

Check if any constraints are violated if exec is scheduled on worker.

Returns:

true if scheduling exec on worker does not violate any constraints, returns false if it does

sortByValues

public <K extends Comparable<K>,V extends Comparable<V>> NavigableMap<K,V> sortByValues(Map<K,V> map)

Used to sort a Map by the values.