public class LocalContainerLauncher extends ContainerLauncher
Launch Containers in local mode.
| Constructor and Description |
|---|
LocalContainerLauncher(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor) |
| 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. |
makepublic LocalContainerLauncher(Map<String,Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor)
public Container launchContainer(int port, LocalAssignment assignment, LocalState state) throws IOException
ContainerLauncherLaunch a container in a given slot.
launchContainer in class ContainerLauncherport - the port to run this onassignment - what to launchstate - the current state of the supervisorIOException - on any errorpublic Container recoverContainer(int port, LocalAssignment assignment, LocalState state) throws IOException
ContainerLauncherRecover a container for a running process.
recoverContainer in class ContainerLauncherport - the port the assignment is running onassignment - the assignment that was launchedstate - the current state of the supervisorIOException - on any errorpublic Killable recoverContainer(String workerId, LocalState localState) throws IOException
ContainerLauncherTry 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.
recoverContainer in class ContainerLauncherworkerId - the id of the worker to uselocalState - the state of the running supervisorIOException - on any errorCopyright © 2021 The Apache Software Foundation. All rights reserved.