org.apache.reef.runtime.local.process

Class RunnableProcess

java.lang.Object

org.apache.reef.runtime.local.process.RunnableProcess

All Implemented Interfaces:

Runnable

public final class RunnableProcess
extends Object
implements Runnable

A runnable class that encapsulates a process.

Constructor Summary

Constructors

Constructor and Description
RunnableProcess(List<String> command, String id, File folder, RunnableProcessObserver processObserver, String standardOutFileName, String standardErrorFileName)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancels the running process if it is running.
static List<String>	expandEnvironmentVariables(List<String> command) Replace {{ENV_VAR}} placeholders with the values of the corresponding environment variables.
static String	expandEnvironmentVariables(String command) Replace {{ENV_VAR}} placeholders with the values of the corresponding environment variables.
List<String>	getCommand()
String	getId()
void	run() Runs the configured process.

Methods inherited from class java.lang.Object

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

Constructor Detail

RunnableProcess

public RunnableProcess(List<String> command,
               String id,
               File folder,
               RunnableProcessObserver processObserver,
               String standardOutFileName,
               String standardErrorFileName)

Parameters:

command - the command to execute.

id - The ID of the process. This is used to name files and in the logs created by this process.

folder - The folder in which this will store its stdout and stderr output

processObserver - will be informed of process state changes.

standardOutFileName - The name of the file used for redirecting STDOUT

standardErrorFileName - The name of the file used for redirecting STDERR

Method Detail

expandEnvironmentVariables

public static String expandEnvironmentVariables(String command)

Replace {{ENV_VAR}} placeholders with the values of the corresponding environment variables.

Parameters:

command - An input string with {{ENV_VAR}} placeholders to be replaced with the values of the corresponding environment variables. Replace unknown/unset variables with an empty string.

Returns:

A new string with all the placeholders expanded.

expandEnvironmentVariables

public static List<String> expandEnvironmentVariables(List<String> command)

Replace {{ENV_VAR}} placeholders with the values of the corresponding environment variables.

Parameters:

command - An input list of strings with {{ENV_VAR}} placeholders to be replaced with the values of the corresponding environment variables. Replace unknown/unset variables with an empty string.

Returns:

A new list of strings with all the placeholders expanded.

run

public void run()

Runs the configured process.

Specified by:

run in interface Runnable

Throws:

IllegalStateException - if the process is already running or has been running before.

cancel

public void cancel()

Cancels the running process if it is running.

getId

public String getId()

Returns:

the ID of the process.

getCommand

public List<String> getCommand()

Returns:

the command given to the process.