| Package | Description |
|---|---|
| backtype.storm.scheduler | |
| backtype.storm.scheduler.multitenant |
| 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.
|
void |
INimbus.assignSlots(Topologies topologies,
Map<String,Collection<WorkerSlot>> newSlotsByTopologyId) |
List<TopologyDetails> |
Cluster.needsSchedulingTopologies(Topologies topologies)
Gets all the topologies which needs scheduling.
|
void |
IScheduler.schedule(Topologies topologies,
Cluster cluster)
Set assignments for the topologies which needs scheduling.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MultitenantScheduler.schedule(Topologies topologies,
Cluster cluster) |
Copyright © 2015. All rights reserved.