Class SynchronizeAssignments
java.lang.Object
org.apache.storm.daemon.supervisor.timer.SynchronizeAssignments
- All Implemented Interfaces:
Runnable
A runnable which will synchronize assignments to node local and then worker processes.
-
Constructor Summary
ConstructorDescriptionSynchronizeAssignments
(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor. -
Method Summary
Modifier and TypeMethodDescriptiongetAllAssignmentsFromNumaSupervisors
(Nimbus.Iface nimbus, String node) void
getAssignmentsFromMaster
(Map conf, IStormClusterState clusterState, String node) Used bySupervisor
to fetch assignments when start up.void
getAssignmentsFromMasterUntilSuccess
(Supervisor supervisor) Used bySupervisor
to fetch assignments when start up.void
run()
-
Constructor Details
-
SynchronizeAssignments
public SynchronizeAssignments(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor.- Parameters:
supervisor
-Supervisor
assignments
-SupervisorAssignments
readClusterState
-ReadClusterState
-
-
Method Details
-
run
public void run() -
getAssignmentsFromMasterUntilSuccess
Used bySupervisor
to fetch assignments when start up.- Parameters:
supervisor
-Supervisor
-
getAllAssignmentsFromNumaSupervisors
public List<SupervisorAssignments> getAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
getAssignmentsFromMaster
Used bySupervisor
to fetch assignments when start up.- Parameters:
conf
- configclusterState
-IStormClusterState
node
- id of node
-