org.apache.storm.daemon.supervisor

Class LocalContainerLauncher

java.lang.Object

org.apache.storm.daemon.supervisor.ContainerLauncher

org.apache.storm.daemon.supervisor.LocalContainerLauncher

public class LocalContainerLauncher
extends ContainerLauncher

Launch Containers in local mode.

Constructor Summary

Constructors

Constructor and Description
LocalContainerLauncher(Map<String,Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor)

Method Summary

Modifier and Type	Method and Description
Container	launchContainer(int port, LocalAssignment assignment, LocalState state) Launch a container in a given slot
Container	recoverContainer(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process
Killable	recoverContainer(String workerId, LocalState localState) Try to recover a container using just the worker ID. The result is really only useful for killing the container and so is returning a Killable.

Methods inherited from class org.apache.storm.daemon.supervisor.ContainerLauncher

make

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalContainerLauncher

public LocalContainerLauncher(Map<String,Object> conf,
                              String supervisorId,
                              int supervisorPort,
                              IContext sharedContext,
                              StormMetricsRegistry metricsRegistry,
                              ContainerMemoryTracker containerMemoryTracker,
                              Supervisor.Iface localSupervisor)

Method Detail

launchContainer

public Container launchContainer(int port,
                                 LocalAssignment assignment,
                                 LocalState state)
                          throws IOException

Description copied from class: ContainerLauncher

Launch a container in a given slot

Specified by:

launchContainer in class ContainerLauncher

Parameters:

port - the port to run this on

assignment - what to launch

state - the current state of the supervisor

Returns:

The container that can be used to manager the processes.

Throws:

IOException - on any error

recoverContainer

public Container recoverContainer(int port,
                                  LocalAssignment assignment,
                                  LocalState state)
                           throws IOException

Description copied from class: ContainerLauncher

Recover a container for a running process

Specified by:

recoverContainer in class ContainerLauncher

Parameters:

port - the port the assignment is running on

assignment - the assignment that was launched

state - the current state of the supervisor

Returns:

The container that can be used to manage the processes.

Throws:

IOException - on any error

recoverContainer

public Killable recoverContainer(String workerId,
                                 LocalState localState)
                          throws IOException

Description copied from class: ContainerLauncher

Try to recover a container using just the worker ID.
The result is really only useful for killing the container and so is returning a Killable. Even if a Container is returned do not case the result to Container because only the Killable APIs are guaranteed to work.

Specified by:

recoverContainer in class ContainerLauncher

Parameters:

workerId - the id of the worker to use

localState - the state of the running supervisor

Returns:

a Killable that can be used to kill the underlying container.

Throws:

IOException - on any error