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 |
ISchedulingState.getAssignmentById(String topologyId)
get the current assignment for the topology.
|
SchedulerAssignment |
Cluster.getAssignmentById(String topologyId) |
Modifier and Type | Method and Description |
---|---|
Map<String,SchedulerAssignment> |
ISchedulingState.getAssignments()
Get all the assignments.
|
Map<String,SchedulerAssignment> |
Cluster.getAssignments() |
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> map,
Topologies topologies,
Map<String,Object> conf) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.