Package | Description |
---|---|
backtype.storm.scheduler |
Modifier and Type | Method and Description |
---|---|
Collection<WorkerSlot> |
INimbus.allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors,
Topologies topologies,
Set<String> topologiesMissingAssignments)
Returns all slots that are available for the next round of scheduling.
|
List<WorkerSlot> |
Cluster.getAssignableSlots() |
List<WorkerSlot> |
Cluster.getAssignableSlots(SupervisorDetails supervisor) |
List<WorkerSlot> |
Cluster.getAvailableSlots()
Gets all the available slots in the cluster.
|
List<WorkerSlot> |
Cluster.getAvailableSlots(SupervisorDetails supervisor)
Return all the available slots on this supervisor.
|
Map<ExecutorDetails,WorkerSlot> |
SchedulerAssignmentImpl.getExecutorToSlot() |
Map<ExecutorDetails,WorkerSlot> |
SchedulerAssignment.getExecutorToSlot()
get the executor -> slot map.
|
Set<WorkerSlot> |
SchedulerAssignmentImpl.getSlots() |
Set<WorkerSlot> |
SchedulerAssignment.getSlots() |
Collection<WorkerSlot> |
Cluster.getUsedSlots() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerAssignmentImpl.assign(WorkerSlot slot,
Collection<ExecutorDetails> executors)
Assign the slot to executors.
|
void |
Cluster.assign(WorkerSlot slot,
String topologyId,
Collection<ExecutorDetails> executors)
Assign the slot to the executors for this topology.
|
void |
Cluster.freeSlot(WorkerSlot slot)
Free the specified slot.
|
boolean |
SchedulerAssignmentImpl.isSlotOccupied(WorkerSlot slot)
Does this slot occupied by this assignment?
|
boolean |
SchedulerAssignment.isSlotOccupied(WorkerSlot slot)
Does this slot occupied by this assignment?
|
boolean |
Cluster.isSlotOccupied(WorkerSlot slot)
Checks the specified slot is occupied.
|
void |
SchedulerAssignmentImpl.unassignBySlot(WorkerSlot slot)
Release the slot occupied by this assignment.
|
Modifier and Type | Method and Description |
---|---|
void |
INimbus.assignSlots(Topologies topologies,
Map<String,Collection<WorkerSlot>> newSlotsByTopologyId) |
void |
Cluster.freeSlots(Collection<WorkerSlot> slots)
free the slots.
|
Constructor and Description |
---|
SchedulerAssignmentImpl(String topologyId,
Map<ExecutorDetails,WorkerSlot> executorToSlots) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.