| 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 © 2021 The Apache Software Foundation. All rights reserved.