Package org.apache.beam.runners.fnexecution.environment

Class ProcessManager

java.lang.Object

org.apache.beam.runners.fnexecution.environment.ProcessManager

@ThreadSafe
public class ProcessManager
extends Object

A simple process manager which forks processes and kills them if necessary.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProcessManager.RunningProcess

Field Summary

Fields

Modifier and Type	Field	Description
static final File	INHERIT_IO_FILE	A symbolic file to indicate that we want to inherit I/O of parent process.

Method Summary

Modifier and Type	Method	Description
static ProcessManager	create()
ProcessManager.RunningProcess	startProcess(String id, String command, List<String> args, Map<String,String> env)	Forks a process with the given command, arguments, and additional environment variables.
ProcessManager.RunningProcess	startProcess(String id, String command, List<String> args, Map<String,String> env, File outputFile)
void	stopProcess(String id)	Stops a previously started process identified by its unique id.

Methods inherited from class java.lang.Object

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

Field Details

INHERIT_IO_FILE

public static final File INHERIT_IO_FILE

A symbolic file to indicate that we want to inherit I/O of parent process.

Method Details

create

public static ProcessManager create()

startProcess

public ProcessManager.RunningProcess startProcess(String id,
 String command,
 List<String> args,
 Map<String,String> env)
                                           throws IOException

Forks a process with the given command, arguments, and additional environment variables.

Parameters:

id - A unique id for the process

command - The name of the executable to run

args - Arguments to provide to the executable

env - Additional environment variables for the process to be forked

Returns:

A RunningProcess which can be checked for liveness

Throws:

IOException

startProcess

public ProcessManager.RunningProcess startProcess(String id,
 String command,
 List<String> args,
 Map<String,String> env,
 File outputFile)
                                           throws IOException

Throws:

IOException

stopProcess

public void stopProcess(String id)

Stops a previously started process identified by its unique id.