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
static class	ConstraintSolverStrategy.ConstraintConfig Component constraint as derived from configuration.
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

Modifier and Type	Field and Description
static String	CONSTRAINT_TYPE_INCOMPATIBLE_COMPONENTS
static String	CONSTRAINT_TYPE_MAX_NODE_CO_LOCATION_CNT

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) Try to schedule till successful or till limits (backtrack count or time) have been exceeded.
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 - higher values up front.
protected TreeSet<BaseResourceAwareStrategy.ObjectResources>	sortObjectResources(BaseResourceAwareStrategy.AllResources allResources, ExecutorDetails exec, TopologyDetails topologyDetails, BaseResourceAwareStrategy.ExistingScheduleFunc existingScheduleFunc)
static boolean	validateSolution(Cluster cluster, TopologyDetails td, ConstraintSolverStrategy.ConstraintConfig constraintConfig) 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

Field Detail

CONSTRAINT_TYPE_MAX_NODE_CO_LOCATION_CNT

public static final String CONSTRAINT_TYPE_MAX_NODE_CO_LOCATION_CNT

See Also:

Constant Field Values

CONSTRAINT_TYPE_INCOMPATIBLE_COMPONENTS

public static final String CONSTRAINT_TYPE_INCOMPATIBLE_COMPONENTS

See Also:

Constant Field Values

Constructor Detail

ConstraintSolverStrategy

public ConstraintSolverStrategy()

Method Detail

validateSolution

public static boolean validateSolution(Cluster cluster,
                                       TopologyDetails td,
                                       ConstraintSolverStrategy.ConstraintConfig constraintConfig)

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)

Try to schedule till successful or till limits (backtrack count or time) have been exceeded.

Parameters:

state - terminal state of the executor assignment.

Returns:

SolverResult with success attribute set to true or false indicting whether ALL executors were assigned.

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 - higher values up front.