public class RunAsUserContainerLauncher extends ContainerLauncher
| Modifier and Type | Field and Description |
|---|---|
protected ResourceIsolationInterface |
_resourceIsolationManager |
| Constructor and Description |
|---|
RunAsUserContainerLauncher(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
ResourceIsolationInterface resourceIsolationManager,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker) |
| 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. |
makeprotected final ResourceIsolationInterface _resourceIsolationManager
public RunAsUserContainerLauncher(Map<String,Object> conf, String supervisorId, int supervisorPort, ResourceIsolationInterface resourceIsolationManager, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker) throws IOException
IOExceptionpublic 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 © 2019 The Apache Software Foundation. All rights reserved.