Uses of Class
org.apache.storm.daemon.supervisor.Supervisor
Package
Description
-
Uses of Supervisor in org.apache.storm
Modifier and TypeMethodDescriptionLocalCluster.addSupervisor()
Add another supervisor to the topology.LocalCluster.addSupervisor
(Number ports) Add another supervisor to the topology.LocalCluster.addSupervisor
(Number ports, String id) Add another supervisor to the topology.Add another supervisor to the topology.LocalCluster.getSupervisor
(String id) Get a specific Supervisor. -
Uses of Supervisor in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionvoid
Nimbus.addSupervisor
(Supervisor supervisor) Used for local cluster. -
Uses of Supervisor in org.apache.storm.daemon.supervisor
-
Uses of Supervisor in org.apache.storm.daemon.supervisor.timer
Modifier and TypeMethodDescriptionvoid
SynchronizeAssignments.getAssignmentsFromMasterUntilSuccess
(Supervisor supervisor) Used bySupervisor
to fetch assignments when start up.ModifierConstructorDescriptionReportWorkerHeartbeats
(Map<String, Object> conf, Supervisor supervisor) SupervisorHealthCheck
(Supervisor supervisor) SupervisorHeartbeat
(Map<String, Object> conf, Supervisor supervisor) SynchronizeAssignments
(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor. -
Uses of Supervisor in org.apache.storm.nimbus
Modifier and TypeMethodDescriptionvoid
AssignmentDistributionService.addLocalSupervisor
(Supervisor supervisor)