backtype.storm.scheduler
Interface SchedulerAssignment

All Known Implementing Classes:

SchedulerAssignmentImpl

public interface SchedulerAssignment

Method Summary

java.util.Set<ExecutorDetails>	getExecutors() Return the executors covered by this assignments
java.util.Map<ExecutorDetails,WorkerSlot>	getExecutorToSlot() get the executor -> slot map.
java.lang.String	getTopologyId() get the topology-id this assignment is for.
boolean	isExecutorAssigned(ExecutorDetails executor) is the executor assigned?
boolean	isSlotOccupied(WorkerSlot slot) Does this slot occupied by this assignment?

Method Detail

isSlotOccupied

boolean isSlotOccupied(WorkerSlot slot)

Does this slot occupied by this assignment?

Parameters:

slot -

Returns:

isExecutorAssigned

boolean isExecutorAssigned(ExecutorDetails executor)

is the executor assigned?

Parameters:

executor -

Returns:

getTopologyId

java.lang.String getTopologyId()

get the topology-id this assignment is for.

Returns:

getExecutorToSlot

java.util.Map<ExecutorDetails,WorkerSlot> getExecutorToSlot()

get the executor -> slot map.

Returns:

getExecutors

java.util.Set<ExecutorDetails> getExecutors()

Return the executors covered by this assignments

Returns: