org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher

Class ContainerLaunch.ShellScriptBuilder

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher.ContainerLaunch.ShellScriptBuilder

Enclosing class:

ContainerLaunch

public abstract static class ContainerLaunch.ShellScriptBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ENV_PRELAUNCH_STDERR
protected static String	ENV_PRELAUNCH_STDOUT

Constructor Summary

Constructors

Constructor and Description
ContainerLaunch.ShellScriptBuilder()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	buildCommand(String... command)
abstract void	command(List<String> command)
abstract void	copyDebugInformation(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst) Method to copy files that are useful for debugging container failures.
static ContainerLaunch.ShellScriptBuilder	create()
abstract void	echo(String echoStr)
abstract void	env(String key, String value)
protected void	line(String... command)
protected void	linebreak(String... command)
protected abstract void	link(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
abstract void	listDebugInformation(org.apache.hadoop.fs.Path output) Method to dump debug information to a target file.
protected abstract void	mkdir(org.apache.hadoop.fs.Path path)
void	setExitOnFailure()
protected abstract void	setStdErr(org.apache.hadoop.fs.Path stdout)
protected abstract void	setStdOut(org.apache.hadoop.fs.Path stdout)
void	stderr(org.apache.hadoop.fs.Path stderrDir, String stdErrFile) Set stderr for the shell script
void	stdout(org.apache.hadoop.fs.Path stdoutDir, String stdOutFile) Set stdout for the shell script
void	symlink(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
String	toString()
void	write(PrintStream out)

Methods inherited from class java.lang.Object

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

Field Detail

ENV_PRELAUNCH_STDOUT

protected static final String ENV_PRELAUNCH_STDOUT

See Also:

Constant Field Values

ENV_PRELAUNCH_STDERR

protected static final String ENV_PRELAUNCH_STDERR

See Also:

Constant Field Values

Constructor Detail

ContainerLaunch.ShellScriptBuilder

public ContainerLaunch.ShellScriptBuilder()

Method Detail

create

public static ContainerLaunch.ShellScriptBuilder create()

command

public abstract void command(List<String> command)
                      throws IOException

Throws:

IOException

stdout

public final void stdout(org.apache.hadoop.fs.Path stdoutDir,
          String stdOutFile)
                  throws IOException

Set stdout for the shell script

Parameters:

stdoutDir - stdout must be an absolute path

stdOutFile - stdout file name

Throws:

IOException - thrown when stdout path is not absolute

stderr

public final void stderr(org.apache.hadoop.fs.Path stderrDir,
          String stdErrFile)
                  throws IOException

Set stderr for the shell script

Parameters:

stderrDir - stderr must be an absolute path

stdErrFile - stderr file name

Throws:

IOException - thrown when stderr path is not absolute

setStdOut

protected abstract void setStdOut(org.apache.hadoop.fs.Path stdout)
                           throws IOException

Throws:

IOException

setStdErr

protected abstract void setStdErr(org.apache.hadoop.fs.Path stdout)
                           throws IOException

Throws:

IOException

env

public abstract void env(String key,
       String value)
                  throws IOException

Throws:

IOException

echo

public abstract void echo(String echoStr)
                   throws IOException

Throws:

IOException

symlink

public final void symlink(org.apache.hadoop.fs.Path src,
           org.apache.hadoop.fs.Path dst)
                   throws IOException

Throws:

IOException

copyDebugInformation

public abstract void copyDebugInformation(org.apache.hadoop.fs.Path src,
                        org.apache.hadoop.fs.Path dst)
                                   throws IOException

Method to copy files that are useful for debugging container failures. This method will be called by ContainerExecutor when setting up the container launch script. The method should take care to make sure files are read-able by the yarn user if the files are to undergo log-aggregation.

Parameters:

src - path to the source file

dst - path to the destination file - should be absolute

Throws:

IOException

listDebugInformation

public abstract void listDebugInformation(org.apache.hadoop.fs.Path output)
                                   throws IOException

Method to dump debug information to a target file. This method will be called by ContainerExecutor when setting up the container launch script.

Parameters:

output - the file to which debug information is to be written

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

write

public final void write(PrintStream out)
                 throws IOException

Throws:

IOException

buildCommand

protected final void buildCommand(String... command)

linebreak

protected final void linebreak(String... command)

line

protected final void line(String... command)

setExitOnFailure

public void setExitOnFailure()

link

protected abstract void link(org.apache.hadoop.fs.Path src,
        org.apache.hadoop.fs.Path dst)
                      throws IOException

Throws:

IOException

mkdir

protected abstract void mkdir(org.apache.hadoop.fs.Path path)
                       throws IOException

Throws:

IOException