org.apache.oozie.action.hadoop
Class PigMain

java.lang.Object
  org.apache.oozie.action.hadoop.LauncherMain
      org.apache.oozie.action.hadoop.PigMain

public class PigMain
extends LauncherMain

Constructor Summary

PigMain()

Method Summary

protected Properties	getHadoopJobIds(String logFile)
static void	main(String[] args)
protected void	run(String[] args)
protected void	runPigJob(String[] args, String pigLog, boolean resetSecurityManager) Runs the pig script using PigRunner API if version 0.8 or above.
static void	setPigScript(org.apache.hadoop.conf.Configuration conf, String script, String[] params, String[] args)

Methods inherited from class org.apache.oozie.action.hadoop.LauncherMain

logMasking, run

Methods inherited from class java.lang.Object

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

Constructor Detail

PigMain

public PigMain()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

run

protected void run(String[] args)
            throws Exception

Specified by:

run in class LauncherMain

Throws:

Exception

runPigJob

protected void runPigJob(String[] args,
                         String pigLog,
                         boolean resetSecurityManager)
                  throws Exception

Runs the pig script using PigRunner API if version 0.8 or above. Embedded pig within python is also supported.

Parameters:

args - pig command line arguments

pigLog - pig log file

resetSecurityManager - specify if need to reset security manager

Throws:

Exception

setPigScript

public static void setPigScript(org.apache.hadoop.conf.Configuration conf,
                                String script,
                                String[] params,
                                String[] args)

getHadoopJobIds

protected Properties getHadoopJobIds(String logFile)
                              throws IOException

Throws:

IOException