Package org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime

Class DefaultLinuxContainerRuntime

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.DefaultLinuxContainerRuntime

All Implemented Interfaces:

LinuxContainerRuntime, ContainerRuntime

Direct Known Subclasses:

JavaSandboxLinuxContainerRuntime

@Private
@Unstable
public class DefaultLinuxContainerRuntime
extends Object
implements LinuxContainerRuntime

This class is a ContainerRuntime implementation that uses the native container-executor binary via a PrivilegedOperationExecutor instance to launch processes using the standard process model.

Constructor Summary

Constructors

Constructor	Description
DefaultLinuxContainerRuntime(PrivilegedOperationExecutor privilegedOperationExecutor)	Create an instance using the given PrivilegedOperationExecutor instance for performing operations.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair	execContainer(ContainerExecContext ctx)	Run a program in container.
String	getExposedPorts(Container container)	Return the exposed ports of the container.
String[]	getIpAndHost(Container container)	Return the host and ip of the container.
void	initialize(org.apache.hadoop.conf.Configuration conf, Context nmContext)	Initialize the runtime.
boolean	isRuntimeRequested(Map<String,String> env)	Return whether the given environment variables indicate that the operation is requesting this runtime.
void	launchContainer(ContainerRuntimeContext ctx)	Launch a container.
void	prepareContainer(ContainerRuntimeContext ctx)	Prepare a container to be ready for launch.
void	reapContainer(ContainerRuntimeContext ctx)	Perform any container cleanup that may be required.
void	relaunchContainer(ContainerRuntimeContext ctx)	Relaunch a container.
void	signalContainer(ContainerRuntimeContext ctx)	Signal a container.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.LinuxContainerRuntime

getLocalResources, start, stop

Constructor Details

DefaultLinuxContainerRuntime

public DefaultLinuxContainerRuntime(PrivilegedOperationExecutor privilegedOperationExecutor)

Create an instance using the given PrivilegedOperationExecutor instance for performing operations.

Parameters:

privilegedOperationExecutor - the PrivilegedOperationExecutor instance

Method Details

isRuntimeRequested

public boolean isRuntimeRequested(Map<String,String> env)

Description copied from interface: LinuxContainerRuntime

Return whether the given environment variables indicate that the operation is requesting this runtime.

Specified by:

isRuntimeRequested in interface LinuxContainerRuntime

Parameters:

env - the environment variable settings for the operation

Returns:

whether this runtime is requested

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf,
 Context nmContext)
                throws ContainerExecutionException

Description copied from interface: LinuxContainerRuntime

Initialize the runtime.

Specified by:

initialize in interface LinuxContainerRuntime

Parameters:

conf - the Configuration to use

nmContext - NMContext

Throws:

ContainerExecutionException - if an error occurs while initializing the runtime

prepareContainer

public void prepareContainer(ContainerRuntimeContext ctx)
                      throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Prepare a container to be ready for launch.

Specified by:

prepareContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerRuntimeContext

Throws:

ContainerExecutionException - if an error occurs while preparing the container

launchContainer

public void launchContainer(ContainerRuntimeContext ctx)
                     throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Launch a container.

Specified by:

launchContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerRuntimeContext

Throws:

ContainerExecutionException - if an error occurs while launching the container

relaunchContainer

public void relaunchContainer(ContainerRuntimeContext ctx)
                       throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Relaunch a container.

Specified by:

relaunchContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerRuntimeContext

Throws:

ContainerExecutionException - if an error occurs while relaunching the container

signalContainer

public void signalContainer(ContainerRuntimeContext ctx)
                     throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Signal a container. Signals may be a request to terminate, a status check, etc.

Specified by:

signalContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerRuntimeContext

Throws:

ContainerExecutionException - if an error occurs while signaling the container

reapContainer

public void reapContainer(ContainerRuntimeContext ctx)
                   throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Perform any container cleanup that may be required.

Specified by:

reapContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerRuntimeContext

Throws:

ContainerExecutionException - if an error occurs while reaping the container

getIpAndHost

public String[] getIpAndHost(Container container)

Description copied from interface: ContainerRuntime

Return the host and ip of the container.

Specified by:

getIpAndHost in interface ContainerRuntime

Parameters:

container - the Container

getExposedPorts

public String getExposedPorts(Container container)

Description copied from interface: ContainerRuntime

Return the exposed ports of the container.

Specified by:

getExposedPorts in interface ContainerRuntime

Parameters:

container - the Container

Returns:

List of exposed ports

execContainer

public org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair execContainer(ContainerExecContext ctx)
                                                                        throws ContainerExecutionException

Description copied from interface: ContainerRuntime

Run a program in container.

Specified by:

execContainer in interface ContainerRuntime

Parameters:

ctx - the ContainerExecContext

Returns:

stdin and stdout of container exec

Throws:

ContainerExecutionException