org.apache.storm.daemon.supervisor

Class Supervisor

java.lang.Object

org.apache.storm.daemon.supervisor.Supervisor

All Implemented Interfaces:

AutoCloseable, DaemonCommon

public class Supervisor
extends Object
implements DaemonCommon, AutoCloseable

Constructor Summary

Constructors

Constructor and Description
Supervisor(Map<String,Object> conf, IContext sharedContext, ISupervisor iSupervisor)

Method Summary

Modifier and Type	Method and Description
void	close()
String	getAssignmentId()
Map<String,Object>	getConf()
AtomicReference<Map<Long,LocalAssignment>>	getCurrAssignment()
String	getHostName()
String	getId()
ISupervisor	getiSupervisor()
Localizer	getLocalizer()
IStormClusterState	getStormClusterState()
String	getStormVersion()
Utils.UptimeComputer	getUpTime()
boolean	isWaiting()
void	launch() Launch the supervisor
void	launchDaemon() start distribute supervisor
static void	main(String[] args) supervisor daemon enter entrance
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

Constructor Detail

Supervisor

public Supervisor(Map<String,Object> conf,
                  IContext sharedContext,
                  ISupervisor iSupervisor)
           throws IOException

Throws:

IOException

Method Detail

getId

public String getId()

getConf

public Map<String,Object> getConf()

getiSupervisor

public ISupervisor getiSupervisor()

getUpTime

public Utils.UptimeComputer getUpTime()

getStormVersion

public String getStormVersion()

getStormClusterState

public IStormClusterState getStormClusterState()

getAssignmentId

public String getAssignmentId()

getHostName

public String getHostName()

getCurrAssignment

public AtomicReference<Map<Long,LocalAssignment>> getCurrAssignment()

getLocalizer

public Localizer getLocalizer()

launch

public void launch()
            throws Exception

Launch the supervisor

Throws:

Exception

launchDaemon

public void launchDaemon()

start distribute supervisor

close

public void close()

Specified by:

close in interface AutoCloseable

shutdownAllWorkers

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

isWaiting

public boolean isWaiting()

Specified by:

isWaiting in interface DaemonCommon

main

public static void main(String[] args)
                 throws Exception

supervisor daemon enter entrance

Parameters:

args -

Throws:

Exception