Uses of Class
org.apache.storm.daemon.supervisor.Supervisor
Packages that use Supervisor
Package
Description
-
Uses of Supervisor in org.apache.storm
Methods in org.apache.storm that return SupervisorModifier 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
Methods in org.apache.storm.daemon.nimbus with parameters of type SupervisorModifier and TypeMethodDescriptionvoid
Nimbus.addSupervisor
(Supervisor supervisor) Used for local cluster. -
Uses of Supervisor in org.apache.storm.daemon.supervisor
Constructors in org.apache.storm.daemon.supervisor with parameters of type Supervisor -
Uses of Supervisor in org.apache.storm.daemon.supervisor.timer
Methods in org.apache.storm.daemon.supervisor.timer with parameters of type SupervisorModifier and TypeMethodDescriptionvoid
SynchronizeAssignments.getAssignmentsFromMasterUntilSuccess
(Supervisor supervisor) Used bySupervisor
to fetch assignments when start up.Constructors in org.apache.storm.daemon.supervisor.timer with parameters of type SupervisorModifierConstructorDescriptionReportWorkerHeartbeats
(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
Methods in org.apache.storm.nimbus with parameters of type SupervisorModifier and TypeMethodDescriptionvoid
AssignmentDistributionService.addLocalSupervisor
(Supervisor supervisor)