| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.daemon.supervisor | |
| org.apache.storm.daemon.supervisor.timer | |
| org.apache.storm.nimbus | 
| Modifier and Type | Method and Description | 
|---|---|
Supervisor | 
LocalCluster.addSupervisor()
Add another supervisor to the topology. 
 | 
Supervisor | 
LocalCluster.addSupervisor(Number ports)
Add another supervisor to the topology. 
 | 
Supervisor | 
LocalCluster.addSupervisor(Number ports,
             Map<String,Object> conf,
             String id)
Add another supervisor to the topology. 
 | 
Supervisor | 
LocalCluster.addSupervisor(Number ports,
             String id)
Add another supervisor to the topology. 
 | 
Supervisor | 
LocalCluster.getSupervisor(String id)
Get a specific Supervisor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Nimbus.addSupervisor(Supervisor supervisor)
Used for local cluster. 
 | 
| Constructor and Description | 
|---|
ReadClusterState(Supervisor supervisor)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SynchronizeAssignments.getAssignmentsFromMasterUntilSuccess(Supervisor supervisor)
Used by  
Supervisor to fetch assignments when start up. | 
| Constructor and Description | 
|---|
ReportWorkerHeartbeats(Map<String,Object> conf,
                      Supervisor supervisor)  | 
SupervisorHealthCheck(Supervisor supervisor)  | 
SupervisorHeartbeat(Map<String,Object> conf,
                   Supervisor supervisor)  | 
SynchronizeAssignments(Supervisor supervisor,
                      SupervisorAssignments assignments,
                      ReadClusterState readClusterState)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AssignmentDistributionService.addLocalSupervisor(Supervisor supervisor)  | 
Copyright © 2019 The Apache Software Foundation. All rights reserved.