Instance Constructors

1.  new PipeDoFn(cmdArray: Array[String], environment: Map[String, String], dir: File, setupCmds: List[Array[String]], teardownCmds: List[Array[String]])

   Create a new PipeDoFn instance.

   Create a new PipeDoFn instance.

   The setup and teardown commands will be executed once per PipeDoFn instance, i.e. on a 4-core Dataflow worker, an instance will be cloned 4 times, one for each CPU core but setup and teardown commands will be executed only once.

   cmdArray

   array containing the command to call and its arguments.

   environment

   environment variables, or null if the subprocess should inherit the environment from the current process.

   dir

   the working directory of the sub process, or null if the subprocess should inherit the working directly of the current process.

   setupCmds

   setup commands to be run before processing.

   teardownCmds

   tear down commands to be run after processing.

2.  new PipeDoFn(command: String, environment: Map[String, String], dir: File, setupCmds: List[String], teardownCmds: List[String])

   Create a new PipeDoFn instance.

   Create a new PipeDoFn instance.

   The setup and teardown commands will be executed once per PipeDoFn instance, i.e. on a 4-core Dataflow worker, an instance will be cloned 4 times, one for each CPU core but setup and teardown commands will be executed only once.

   command

   the command to call.

   environment

   environment variables, or null if the subprocess should inherit the environment from the current process.

   dir

   the working directory of the sub process, or null if the subprocess should inherit the working directly of the current process.

   setupCmds

   setup commands to be run before processing.

   teardownCmds

   tear down commands to be run after processing.

3.  new PipeDoFn(cmdArray: Array[String])

   Create a new PipeDoFn instance.

   Create a new PipeDoFn instance.

   cmdArray

   array containing the command to call and its arguments.

4.  new PipeDoFn(command: String)