org.apache.storm.scheduler

Interface SchedulerAssignment

All Known Implementing Classes:

SchedulerAssignmentImpl

public interface SchedulerAssignment

Method Summary

Modifier and Type	Method and Description
Set<ExecutorDetails>	getExecutors() Return the executors covered by this assignments
Map<ExecutorDetails,WorkerSlot>	getExecutorToSlot() get the executor -> slot map.
Set<WorkerSlot>	getSlots()
Map<WorkerSlot,Collection<ExecutorDetails>>	getSlotToExecutors()
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

String getTopologyId()

get the topology-id this assignment is for.

Returns:

getExecutorToSlot

Map<ExecutorDetails,WorkerSlot> getExecutorToSlot()

get the executor -> slot map.

Returns:

getExecutors

Set<ExecutorDetails> getExecutors()

Return the executors covered by this assignments

Returns:

getSlots

Set<WorkerSlot> getSlots()

getSlotToExecutors

Map<WorkerSlot,Collection<ExecutorDetails>> getSlotToExecutors()