| Package | Description |
|---|---|
| backtype.storm.scheduler | |
| backtype.storm.scheduler.multitenant |
| Modifier and Type | Method and Description |
|---|---|
TopologyDetails |
Topologies.getById(String topologyId) |
TopologyDetails |
Topologies.getByName(String topologyName) |
| Modifier and Type | Method and Description |
|---|---|
Collection<TopologyDetails> |
Topologies.getTopologies() |
List<TopologyDetails> |
Cluster.needsSchedulingTopologies(Topologies topologies)
Gets all the topologies which needs scheduling.
|
| Modifier and Type | Method and Description |
|---|---|
int |
Cluster.getAssignedNumWorkers(TopologyDetails topology)
Gets the number of workers assigned to this topology.
|
Map<String,List<ExecutorDetails>> |
Cluster.getNeedsSchedulingComponentToExecutors(TopologyDetails topology)
Gets a component-id -> executors map which needs scheduling in this topology.
|
Map<ExecutorDetails,String> |
Cluster.getNeedsSchedulingExecutorToComponents(TopologyDetails topology)
Gets a executor -> component-id map which needs scheduling in this topology.
|
Collection<ExecutorDetails> |
Cluster.getUnassignedExecutors(TopologyDetails topology)
get the unassigned executors of the topology.
|
boolean |
Cluster.needsScheduling(TopologyDetails topology)
Does the topology need scheduling?
A topology needs scheduling if one of the following conditions holds:
Although the topology is assigned slots, but is squeezed.
|
| Constructor and Description |
|---|
Topologies(Map<String,TopologyDetails> topologies) |
| Modifier and Type | Method and Description |
|---|---|
void |
FreePool.addTopology(TopologyDetails td) |
void |
DefaultPool.addTopology(TopologyDetails td) |
void |
IsolatedPool.addTopology(TopologyDetails td) |
abstract void |
NodePool.addTopology(TopologyDetails td)
Add a topology to the pool
|
boolean |
FreePool.canAdd(TopologyDetails td) |
boolean |
DefaultPool.canAdd(TopologyDetails td) |
boolean |
IsolatedPool.canAdd(TopologyDetails td) |
abstract boolean |
NodePool.canAdd(TopologyDetails td)
Check if this topology can be added to this pool
|
| Constructor and Description |
|---|
NodePool.RoundRobinSlotScheduler(TopologyDetails td,
int slotsToUse,
Cluster cluster)
Create a new scheduler for a given topology
|
Copyright © 2015. All rights reserved.