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() Get the set of all executors.
Map<ExecutorDetails,WorkerSlot>	getExecutorToSlot() Get the map of executor to WorkerSlot.
Map<String,Double>	getNodeIdToTotalSharedOffHeapNodeMemory() Get the total shared off heap node memory mapping.
Map<WorkerSlot,WorkerResources>	getScheduledResources() Get the slot to resource mapping.
Set<WorkerSlot>	getSlots() Get the set of all slots that are a part of this.
Map<WorkerSlot,Collection<ExecutorDetails>>	getSlotToExecutors() Get the mapping of slot to executors on that slot.
String	getTopologyId() Return the ID of the topology.
boolean	isExecutorAssigned(ExecutorDetails executor) Is the executor assigned or not.
boolean	isSlotOccupied(WorkerSlot slot) Is this slot part of this assignment or not.

Method Detail

isSlotOccupied

boolean isSlotOccupied(WorkerSlot slot)

Is this slot part of this assignment or not.

Parameters:

slot - the slot to check.

Returns:

true if the slot is occupied by this assignment else false.

isExecutorAssigned

boolean isExecutorAssigned(ExecutorDetails executor)

Is the executor assigned or not.

Parameters:

executor - the executor to check it if is assigned.

Returns:

true if it is assigned else false

getTopologyId

String getTopologyId()

Return the ID of the topology.

Returns:

the topology-id this assignment is for.

getExecutorToSlot

Map<ExecutorDetails,WorkerSlot> getExecutorToSlot()

Get the map of executor to WorkerSlot.

Returns:

the executor -> slot map.

getExecutors

Set<ExecutorDetails> getExecutors()

Get the set of all executors.

Returns:

the executors covered by this assignments

getSlots

Set<WorkerSlot> getSlots()

Get the set of all slots that are a part of this.

Returns:

the set of all slots.

getSlotToExecutors

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

Get the mapping of slot to executors on that slot.

Returns:

the slot to the executors assigned to that slot.

getScheduledResources

Map<WorkerSlot,WorkerResources> getScheduledResources()

Get the slot to resource mapping.

Returns:

The slot to resource mapping

getNodeIdToTotalSharedOffHeapNodeMemory

Map<String,Double> getNodeIdToTotalSharedOffHeapNodeMemory()

Get the total shared off heap node memory mapping.

Returns:

host to total shared off heap node memory mapping.