Class ReadClusterState
- java.lang.Object
-
- org.apache.storm.daemon.supervisor.ReadClusterState
-
- All Implemented Interfaces:
AutoCloseable,Runnable
public class ReadClusterState extends Object implements Runnable, AutoCloseable
-
-
Field Summary
Fields Modifier and Type Field Description static UniFunc<Slot>DEFAULT_ON_ERROR_TIMEOUTstatic BiConsumer<Slot,Long>DEFAULT_ON_WARN_TIMEOUTstatic UniFunc<Slot>THREAD_DUMP_ON_ERROR
-
Constructor Summary
Constructors Constructor Description ReadClusterState(Supervisor supervisor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()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)
-
-
-
Constructor Detail
-
ReadClusterState
public ReadClusterState(Supervisor supervisor) throws Exception
- Throws:
Exception
-
-
Method Detail
-
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
protected Map<Integer,LocalAssignment> readAssignments(Map<String,Assignment> assignmentsSnapshot)
-
readMyExecutors
protected Map<Integer,LocalAssignment> readMyExecutors(String topoId, String assignmentId, Assignment assignment)
-
shutdownAllWorkers
public void shutdownAllWorkers(BiConsumer<Slot,Long> onWarnTimeout, UniFunc<Slot> onErrorTimeout)
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable
-
-