Class ReadClusterState
java.lang.Object
org.apache.storm.daemon.supervisor.ReadClusterState
- All Implemented Interfaces:
- AutoCloseable,- Runnable
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()protected Map<String,Assignment> getAssignmentsSnapshot(IStormClusterState stormClusterState) protected Map<String,List<ProfileRequest>> getProfileActions(IStormClusterState stormClusterState, List<String> stormIds) protected Map<Integer,LocalAssignment> readAssignments(Map<String, Assignment> assignmentsSnapshot) protected Map<Integer,LocalAssignment> readMyExecutors(String topoId, String assignmentId, Assignment assignment) voidrun()voidshutdownAllWorkers(BiConsumer<Slot, Long> onWarnTimeout, UniFunc<Slot> onErrorTimeout) 
- 
Field Details- 
DEFAULT_ON_ERROR_TIMEOUT
- 
THREAD_DUMP_ON_ERROR
- 
DEFAULT_ON_WARN_TIMEOUT
 
- 
- 
Constructor Details- 
ReadClusterState- Throws:
- Exception
 
 
- 
- 
Method Details- 
runpublic void run()
- 
getAssignmentsSnapshotprotected Map<String,Assignment> getAssignmentsSnapshot(IStormClusterState stormClusterState) throws Exception - Throws:
- Exception
 
- 
getProfileActionsprotected Map<String,List<ProfileRequest>> getProfileActions(IStormClusterState stormClusterState, List<String> stormIds) throws Exception - Throws:
- Exception
 
- 
readAssignments
- 
readMyExecutorsprotected Map<Integer,LocalAssignment> readMyExecutors(String topoId, String assignmentId, Assignment assignment) 
- 
shutdownAllWorkers
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
 
 
-