org.apache.storm.daemon.supervisor

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 and Description
static UniFunc<Slot>	DEFAULT_ON_ERROR_TIMEOUT
static UniFunc<Slot>	DEFAULT_ON_WARN_TIMEOUT
static UniFunc<Slot>	THREAD_DUMP_ON_ERROR

Constructor Summary

Constructors

Constructor and Description
ReadClusterState(Supervisor supervisor)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Map<String,VersionedData<Assignment>>	getAssignmentsSnapshot(IStormClusterState stormClusterState, List<String> topoIds, Map<String,VersionedData<Assignment>> localAssignmentVersion, Runnable callback)
protected Map<String,List<ProfileRequest>>	getProfileActions(IStormClusterState stormClusterState, List<String> stormIds)
protected Map<Integer,LocalAssignment>	readAssignments(Map<String,VersionedData<Assignment>> assignmentsSnapshot)
protected Map<Integer,LocalAssignment>	readMyExecutors(String stormId, String assignmentId, Assignment assignment)
void	run()
void	shutdownAllWorkers(UniFunc<Slot> onWarnTimeout, UniFunc<Slot> onErrorTimeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_ON_ERROR_TIMEOUT

public static final UniFunc<Slot> DEFAULT_ON_ERROR_TIMEOUT

DEFAULT_ON_WARN_TIMEOUT

public static final UniFunc<Slot> DEFAULT_ON_WARN_TIMEOUT

THREAD_DUMP_ON_ERROR

public static final UniFunc<Slot> THREAD_DUMP_ON_ERROR

Constructor Detail

ReadClusterState

public ReadClusterState(Supervisor supervisor)
                 throws Exception

Throws:

Exception

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getAssignmentsSnapshot

protected Map<String,VersionedData<Assignment>> getAssignmentsSnapshot(IStormClusterState stormClusterState,
                                                                       List<String> topoIds,
                                                                       Map<String,VersionedData<Assignment>> localAssignmentVersion,
                                                                       Runnable callback)
                                                                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,VersionedData<Assignment>> assignmentsSnapshot)

readMyExecutors

protected Map<Integer,LocalAssignment> readMyExecutors(String stormId,
                                                       String assignmentId,
                                                       Assignment assignment)

shutdownAllWorkers

public void shutdownAllWorkers(UniFunc<Slot> onWarnTimeout,
                               UniFunc<Slot> onErrorTimeout)

close

public void close()

Specified by:

close in interface AutoCloseable