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.

Method Summary

Modifier and Type	Method and Description
static ProcessManager	create()
org.apache.beam.runners.fnexecution.environment.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.
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

Method Detail

create

public static ProcessManager create()

startProcess

public org.apache.beam.runners.fnexecution.environment.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

stopProcess

public void stopProcess(String id)

Stops a previously started process identified by its unique id.