| Package | Description | 
|---|---|
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.scheduler | 
| Constructor and Description | 
|---|
| TopologyResources(TopologyDetails td,
                 SchedulerAssignment assignment) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SchedulerAssignmentImpl | 
| Modifier and Type | Method and Description | 
|---|---|
| SchedulerAssignment | Cluster. getAssignmentById(String topologyId) | 
| SchedulerAssignment | ISchedulingState. getAssignmentById(String topologyId)get the current assignment for the topology. | 
| Modifier and Type | Method and Description | 
|---|---|
| Map<String,SchedulerAssignment> | Cluster. getAssignments() | 
| Map<String,SchedulerAssignment> | ISchedulingState. getAssignments()Get all the assignments. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Cluster. assign(SchedulerAssignment assignment,
      boolean ignoreSingleExceptions)Assign everything for the given topology. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Cluster. setAssignments(Map<String,? extends SchedulerAssignment> newAssignments,
              boolean ignoreSingleExceptions)Set assignments for cluster. | 
| Constructor and Description | 
|---|
| SchedulerAssignmentImpl(SchedulerAssignment assignment) | 
| Constructor and Description | 
|---|
| Cluster(INimbus nimbus,
       ResourceMetrics resourceMetrics,
       Map<String,SupervisorDetails> supervisors,
       Map<String,? extends SchedulerAssignment> assignments,
       Topologies topologies,
       Map<String,Object> conf) | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.