org.apache.pig.impl.streaming
Class StreamingUtil

java.lang.Object
  org.apache.pig.impl.streaming.StreamingUtil

public class StreamingUtil
extends Object

Constructor Summary

StreamingUtil()

Method Summary

protected static void	addJobConfToEnvironment(org.apache.hadoop.conf.Configuration conf, Map<String,String> env)
static ProcessBuilder	createProcess(StreamingCommand command) Create an external process for StreamingCommand command.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingUtil

public StreamingUtil()

Method Detail

createProcess

public static ProcessBuilder createProcess(StreamingCommand command)

Create an external process for StreamingCommand command.

Parameters:

command -

Returns:

addJobConfToEnvironment

protected static void addJobConfToEnvironment(org.apache.hadoop.conf.Configuration conf,
                                              Map<String,String> env)