Class ReadClusterState
java.lang.Object
org.apache.storm.daemon.supervisor.ReadClusterState
- All Implemented Interfaces:
AutoCloseable
,Runnable
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
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) void
run()
void
shutdownAllWorkers
(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
-
run
public void run() -
getAssignmentsSnapshot
protected Map<String,Assignment> getAssignmentsSnapshot(IStormClusterState stormClusterState) throws Exception - Throws:
Exception
-
getProfileActions
protected Map<String,List<ProfileRequest>> getProfileActions(IStormClusterState stormClusterState, List<String> stormIds) throws Exception - Throws:
Exception
-
readAssignments
-
readMyExecutors
protected Map<Integer,LocalAssignment> readMyExecutors(String topoId, String assignmentId, Assignment assignment) -
shutdownAllWorkers
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-