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