org.apache.storm.daemon.supervisor

Class Slot

java.lang.Object

java.lang.Thread

org.apache.storm.daemon.supervisor.Slot

All Implemented Interfaces:

AutoCloseable, Runnable

public class Slot
extends Thread
implements AutoCloseable

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Slot(ILocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor iSupervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments)

Method Summary

Modifier and Type	Method and Description
void	addProfilerActions(Set<org.apache.storm.daemon.supervisor.Slot.TopoProfileAction> actions)
void	close()
org.apache.storm.daemon.supervisor.Slot.MachineState	getMachineState()
String	getWorkerId()
void	run()
void	setNewAssignment(LocalAssignment newAssignment) Set a new assignment asynchronously

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

Slot

public Slot(ILocalizer localizer,
            Map<String,Object> conf,
            ContainerLauncher containerLauncher,
            String host,
            int port,
            LocalState localState,
            IStormClusterState clusterState,
            ISupervisor iSupervisor,
            AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments)
     throws Exception

Throws:

Exception

Method Detail

getMachineState

public org.apache.storm.daemon.supervisor.Slot.MachineState getMachineState()

setNewAssignment

public void setNewAssignment(LocalAssignment newAssignment)

Set a new assignment asynchronously

Parameters:

newAssignment - the new assignment for this slot to run, null to run nothing

addProfilerActions

public void addProfilerActions(Set<org.apache.storm.daemon.supervisor.Slot.TopoProfileAction> actions)

getWorkerId

public String getWorkerId()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception