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

Class ConstraintSolverStrategy.SearcherState

java.lang.Object

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

Enclosing class:

ConstraintSolverStrategy

protected static final class ConstraintSolverStrategy.SearcherState
extends Object

Method Summary

Modifier and Type	Method and Description
boolean	areAllExecsScheduled()
boolean	areSearchLimitsExceeded()
void	backtrack(Map<ExecutorDetails,String> execToComp, RasNode node, WorkerSlot workerSlot)
ExecutorDetails	currentExec()
int	getExecSize()
int	getStatesSearched()
void	incStatesSearched()
void	logNodeCompAssignments() Use this method to log the current component assignments on the Node.
ConstraintSolverStrategy.SearcherState	nextExecutor()
void	tryToSchedule(Map<ExecutorDetails,String> execToComp, RasNode node, WorkerSlot workerSlot) Assign executor to worker and node.

Methods inherited from class java.lang.Object

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

Method Detail

incStatesSearched

public void incStatesSearched()

getStatesSearched

public int getStatesSearched()

getExecSize

public int getExecSize()

areSearchLimitsExceeded

public boolean areSearchLimitsExceeded()

nextExecutor

public ConstraintSolverStrategy.SearcherState nextExecutor()

areAllExecsScheduled

public boolean areAllExecsScheduled()

currentExec

public ExecutorDetails currentExec()

tryToSchedule

public void tryToSchedule(Map<ExecutorDetails,String> execToComp,
                          RasNode node,
                          WorkerSlot workerSlot)

Assign executor to worker and node. TODO: tryToSchedule is a misnomer, since it always schedules. Assignment validity check is done before the call to tryToSchedule().

Parameters:

execToComp - Mapping from executor to component name.

node - RasNode on which to schedule.

workerSlot - WorkerSlot on which to schedule.

backtrack

public void backtrack(Map<ExecutorDetails,String> execToComp,
                      RasNode node,
                      WorkerSlot workerSlot)

logNodeCompAssignments

public void logNodeCompAssignments()

Use this method to log the current component assignments on the Node. Useful for debugging and tests.