Package | Description |
---|---|
backtype.storm.scheduler |
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) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.