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 SummaryConstructorsConstructorDescriptionSynchronizeAssignments(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptiongetAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node) voidgetAssignmentsFromMaster(Map conf, IStormClusterState clusterState, String node) Used bySupervisorto fetch assignments when start up.voidrun()
- 
Constructor Details- 
SynchronizeAssignmentspublic SynchronizeAssignments(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor.- Parameters:
- supervisor-- Supervisor
- assignments-- SupervisorAssignments
- readClusterState-- ReadClusterState
 
 
- 
- 
Method Details- 
runpublic void run()
- 
getAllAssignmentsFromNumaSupervisorspublic List<SupervisorAssignments> getAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getAssignmentsFromMasterUsed bySupervisorto fetch assignments when start up.- Parameters:
- conf- config
- clusterState-- IStormClusterState
- node- id of node
 
 
-