org.apache.pig.impl.streaming
Class StreamingUtil

java.lang.Object
  extended by 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)


Copyright © 2007-2012 The Apache Software Foundation